spawn workflow fix

hatchet-dev · Jan 20, 2025 · 361fecb · 361fecb
1 parent 0c85079
commit 361fecb
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/python/hatchet.py b/python/hatchet.py
@@ -13,10 +13,11 @@ def step1(self, context: Context):
         }
 
     @hatchet.step(name="step2", parents=["step1"])
-    def step2(self, context: Context):
+    async def step2(self, context: Context):
         context.log("Called step2")
 
-        context.spawn_workflow("quickstart-child-python", {}).result()
+        res = await context.aio.spawn_workflow("quickstart-child-python", {})
+        await res.result()
 
         return {
             "result": "This is a step which spawned a child workflow."