Skip to content

Commit fc1c8e7

Browse files
committed
fixup errors
Signed-off-by: Neil South <[email protected]>
1 parent 318ab3a commit fc1c8e7

File tree

7 files changed

+20
-6
lines changed

7 files changed

+20
-6
lines changed

src/WorkflowManager/Contracts/Migrations/M001_ExecutionStats_addVersion.cs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,9 @@ public override void Down(BsonDocument document)
3434
{
3535
document.Remove("Version");
3636
}
37-
catch { } // can ignore we dont want failures stopping startup !
37+
catch
38+
{ // can ignore we dont want failures stopping startup !
39+
}
3840
}
3941
}
4042
}

src/WorkflowManager/Contracts/Migrations/M001_Payload_addVerion.cs

100755100644
Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,9 @@ public override void Down(BsonDocument document)
3333
{
3434
document.Remove("Version");
3535
}
36-
catch { }// can ignore we dont want failures stopping startup !
36+
catch
37+
{ // can ignore we dont want failures stopping startup !
38+
}
3739
}
3840
}
3941
}

src/WorkflowManager/Contracts/Migrations/M001_WorkflowInstance_addVerion.cs

100755100644
Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,9 @@ public override void Down(BsonDocument document)
3333
{
3434
document.Remove("Version");
3535
}
36-
catch { }// can ignore we dont want failures stopping startup !
36+
catch
37+
{ // can ignore we dont want failures stopping startup !
38+
}
3739
}
3840
}
3941
}

src/WorkflowManager/Contracts/Migrations/M001_WorkflowRevision_addVerion.cs

100755100644
Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,9 @@ public override void Down(BsonDocument document)
3333
{
3434
document.Remove("Version");
3535
}
36-
catch { }// can ignore we dont want failures stopping startup !
36+
catch
37+
{ // can ignore we dont want failures stopping startup !
38+
}
3739
}
3840
}
3941
}

src/WorkflowManager/Contracts/Migrations/M002_ExecutionStats_addWorkflowId.cs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,9 @@ public override void Down(BsonDocument document)
3434
{
3535
document.Remove("WorkflowId");
3636
}
37-
catch { }// can ignore we dont want failures stopping startup !
37+
catch
38+
{ // can ignore we dont want failures stopping startup !
39+
}
3840
}
3941
}
4042
}

src/WorkflowManager/Contracts/Migrations/M002_Payload_addPayloadDeleted.cs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,9 @@ public override void Down(BsonDocument document)
3434
{
3535
document.Remove("PayloadDeleted");
3636
}
37-
catch { }// can ignore we dont want failures stopping startup !
37+
catch
38+
{ // can ignore we dont want failures stopping startup !
39+
}
3840
}
3941
}
4042
}

src/WorkflowManager/WorkflowExecuter/Services/WorkflowExecuterService.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -280,6 +280,8 @@ public async Task<bool> ProcessTaskUpdate(TaskUpdateEvent message)
280280
return false;
281281
}
282282

283+
currentTask.WorkflowInstanceId = message.WorkflowInstanceId;
284+
283285
if (message.Reason == FailureReason.TimedOut && currentTask.Status == TaskExecutionStatus.Failed)
284286
{
285287
_logger.TaskTimedOut(message.TaskId, message.WorkflowInstanceId, currentTask.Timeout);

0 commit comments

Comments
 (0)