Merge pull request #433 from serverlessworkflow/fix-task-cloud-event-status

cdavernas · web-flow · commit c17375693db9 · 2024-10-21T16:17:27.000+02:00
Fixed the `WorkflowExecutionContext` to properly set the status of an ended task
diff --git a/src/runner/Synapse.Runner/Services/WorkflowExecutionContext.cs b/src/runner/Synapse.Runner/Services/WorkflowExecutionContext.cs
@@ -538,7 +538,7 @@ await this.Api.Events.PublishAsync(new CloudEvent()
                 {
                     Workflow = this.Instance.GetQualifiedName(),
                     Task = task.Reference,
-                    Status = this.Instance.Status!.Phase!,
+                    Status = task.Status!,
                     EndedAt = run?.EndedAt ?? DateTimeOffset.Now
                 }
             }, cancellationToken).ConfigureAwait(false);

Original file line number	Diff line number	Diff line change
`@@ -538,7 +538,7 @@ await this.Api.Events.PublishAsync(new CloudEvent()`
`538`	`538`	`{`
`539`	`539`	`Workflow = this.Instance.GetQualifiedName(),`
`540`	`540`	`Task = task.Reference,`
`541`		`- Status = this.Instance.Status!.Phase!,`
	`541`	`+ Status = task.Status!,`
`542`	`542`	`EndedAt = run?.EndedAt ?? DateTimeOffset.Now`
`543`	`543`	`}`
`544`	`544`	`}, cancellationToken).ConfigureAwait(false);`