src/Hotline/FlowEngine/Workflows/WorkflowDomainService.cs

@@ -539,7 +539,7 @@ namespace Hotline.FlowEngine.Workflows
 
             await _publisher.PublishAsync(
                 new NextStepNotify(workflow, dto, flowAssignInfo, trace, nextStepDefine,
-                    current.RequiredOrgId, expiredTime.HasValue), PublishStrategy.ParallelNoWait,
+                    current.RequiredOrgId, expiredTime.HasValue), PublishStrategy.ParallelWhenAll,
                 cancellationToken);
         }
 
@@ -1283,7 +1283,7 @@ namespace Hotline.FlowEngine.Workflows
             workflow.Terminate(dto.Opinion);
             await _workflowRepository.UpdateAsync(workflow, cancellationToken);
 
-            await _publisher.PublishAsync(new TerminalWorkflowNotify(workflow), PublishStrategy.ParallelNoWait,
+            await _publisher.PublishAsync(new TerminalWorkflowNotify(workflow), PublishStrategy.ParallelWhenAll,
                 cancellationToken);
         }
 
@@ -1385,7 +1385,7 @@ namespace Hotline.FlowEngine.Workflows
             var endTrace = await EndAsync(workflow, basicDto, endStepDefine, currentStep, current,
                 expiredTime, cancellationToken: cancellationToken);
 
-            await _publisher.PublishAsync(new CancelWorkflowNotify(workflow), PublishStrategy.ParallelNoWait,
+            await _publisher.PublishAsync(new CancelWorkflowNotify(workflow), PublishStrategy.ParallelWhenAll,
                 cancellationToken);
         }
 
@@ -1787,7 +1787,7 @@ namespace Hotline.FlowEngine.Workflows
             //create trace
             await CreateTraceAsync(workflow, countersignEndStep, EWorkflowTraceType.Normal, cancellationToken);
 
-            await _publisher.PublishAsync(new CountersignEndAssigned(workflow), PublishStrategy.ParallelNoWait,
+            await _publisher.PublishAsync(new CountersignEndAssigned(workflow), PublishStrategy.ParallelWhenAll,
                 cancellationToken);
             //}