Skip to content

Commit 50869e1

Browse files
authored
Merge pull request #812 from glucaci/fixExecutePhaseSample
Fix execute workflow phase sample
2 parents db42f91 + 15df831 commit 50869e1

File tree

1 file changed

+13
-4
lines changed

1 file changed

+13
-4
lines changed

ReleaseNotes/3.4.0.md

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,18 +38,27 @@ public class MetricsMiddleware : IWorkflowMiddleware
3838
switch (workflow.Status)
3939
{
4040
case WorkflowStatus.Complete:
41-
if (_suspendedWorkflows.TryRemove(workflow.Id))
42-
{
43-
_suspended.Dec();
44-
}
41+
TryDecrementSuspended(workflow);
4542
_completed.Inc();
4643
break;
4744
case WorkflowStatus.Suspended:
45+
_suspendedWorkflows.Add(workflow.Id);
4846
_suspended.Inc();
4947
break;
48+
default:
49+
TryDecrementSuspended(workflow);
50+
break;
5051
}
5152

5253
return next();
5354
}
55+
56+
private void TryDecrementSuspended(WorkflowInstance workflow)
57+
{
58+
if (_suspendedWorkflows.TryRemove(workflow.Id))
59+
{
60+
_suspended.Dec();
61+
}
62+
}
5463
}
5564
```

0 commit comments

Comments
 (0)