diff --git a/WorkflowConcurrency/Sources/AsyncSequenceWorker.swift b/WorkflowConcurrency/Sources/AsyncSequenceWorker.swift
index f1e621c3a..df717e6c5 100644
--- a/WorkflowConcurrency/Sources/AsyncSequenceWorker.swift
+++ b/WorkflowConcurrency/Sources/AsyncSequenceWorker.swift
@@ -51,8 +51,12 @@ struct AsyncSequenceWorkerWorkflow<WorkerType: AsyncSequenceWorker>: Workflow {
         context.runSideEffect(key: state) { lifetime in
             let sequence = worker.run()
             let task = Task { @MainActor in
-                for try await output in sequence {
-                    sink.send(AnyWorkflowAction(sendingOutput: output))
+                do {
+                    for try await output in sequence {
+                        sink.send(AnyWorkflowAction(sendingOutput: output))
+                    }
+                } catch {
+                    fatalError("AsyncSequenceWorker implementations should not throw errors on iteration: \(error)")
                 }
             }