diff --git a/src/runner/Synapse.Runner/Services/WorkflowExecutionContext.cs b/src/runner/Synapse.Runner/Services/WorkflowExecutionContext.cs
index 105169221..ac81ce7fc 100644
--- 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);