diff --git a/chatkit/agents.py b/chatkit/agents.py
index daddab5..5ace8d2 100644
--- a/chatkit/agents.py
+++ b/chatkit/agents.py
@@ -165,7 +165,7 @@ async def start_workflow(self, workflow: Workflow) -> None:
             # Defer sending added event until we have tasks
             return
 
-            await self.stream(ThreadItemAddedEvent(item=self.workflow_item))
+        await self.stream(ThreadItemAddedEvent(item=self.workflow_item))
 
     async def update_workflow_task(self, task: Task, task_index: int) -> None:
         """Update an existing workflow task and stream the delta."""