feat: coroutines

Author: grutt

simple-examples/poetry.lock

@@ -14,7 +14,7 @@ python-dotenv = "^1.0.0"
 openai = "^1.12.0"
 beautifulsoup4 = "^4.12.3"
 requests = "^2.31.0"
-hatchet-sdk = "^0.15.0"
+hatchet-sdk = "^0.15.4"
 
 [build-system]
 requires = ["poetry-core"]

simple-examples/pyproject.toml

@@ -0,0 +1,8 @@
+from src.hatchet import hatchet
+
+hatchet.client.event.push(
+    "async:create",
+    {
+        "test": "test"
+    }
+)

simple-examples/src/async/__init__.py

@@ -0,0 +1,20 @@
+from hatchet_sdk import Context
+from src.hatchet import hatchet
+import asyncio
+
+
+@hatchet.workflow(on_events=["async:create"])
+class AsyncWorkflow:
+
+    @hatchet.step()
+    async def step1(self, context: Context):
+        print("sleeping...")
+        await asyncio.sleep(5)
+        print("...done sleeping")
+
+        return {"step1": "complete!"}
+
+
+worker = hatchet.worker("example-worker")
+worker.register_workflow(AsyncWorkflow())
+worker.start()