feat: init simple example

Author: grutt

simple-examples/__init__.py

@@ -0,0 +1,7 @@
+from hatchet_sdk import Hatchet
+from dotenv import load_dotenv
+
+load_dotenv()
+
+# Create a Hatchet instance that will be shared across all workflows
+hatchet = Hatchet()

simple-examples/hatchet.py

@@ -0,0 +1,15 @@
+from .hatchet import hatchet
+from .simple import SimpleWorkflow
+
+# This is the entry point for the Hatchet worker process
+
+
+def start():
+    worker = hatchet.worker('example-worker')
+
+    # Instantiate the workflow and Register the workflow with the worker
+    simple = SimpleWorkflow()
+    worker.register_workflow(simple)
+
+    # Start the worker and begin listening for events
+    worker.start()

simple-examples/main.py

@@ -0,0 +1,25 @@
+[tool.poetry]
+name = "src"
+version = "0.0.0"
+description = "Easily run background tasks in FastAPI with Hatchet"
+authors = []
+readme = "README.md"
+
+[tool.poetry.scripts]
+api = "src.api.main:start"
+hatchet = "src.workflows.main:start"
+
+[tool.poetry.dependencies]
+python = "^3.8"
+python-dotenv = "^1.0.0"
+hatchet-sdk = "^0.9.4"
+uvicorn = {extras = ["standard"], version = "^0.27.0"}
+fastapi = "^0.109.0"
+beautifulsoup4 = "^4.12.3"
+requests = "^2.31.0"
+urllib3 = "1.26.15"
+
+[build-system]
+requires = ["poetry-core"]
+build-backend = "poetry.core.masonry.api"
+

simple-examples/pyproject.toml

@@ -0,0 +1,27 @@
+from .hatchet import hatchet
+from hatchet_sdk import Context
+
+# This is a simple example of a workflow that has 3 steps.
+# The workflow is declared decorated with `@hatchet_workflow` and the steps are declared with `@hatchet_step`.
+
+
+@hatchet.workflow(on_events=["simple:create"])
+class SimpleWorkflow:
+
+    @hatchet.step()
+    def step1(self, context: Context):
+
+        # The context object is passed to each step and contains the input data for the workflow.
+        messages = context.workflow_input()['request']['messages']
+        print("> starting step1", messages)
+        return {"status": "thinking"}
+
+    @hatchet.step(parents=["step1"])
+    def step2(self, context: Context):
+        print("starting step2")
+        return {"status": "writing a response"}
+
+    @hatchet.step(parents=["step2"], timeout='5m')
+    def step3(self, context: Context):
+        messages = context.workflow_input()['request']['messages']
+        return {"complete": "true", "status": "idle", "message": "response from step3"}