python-temporal

# Temporal Workflow Orchestration Temporal SDK patterns for building durable, distributed workflows in Python. ## Worker Setup ```python from temporalio.client import Client from temporalio.worker import Worker async def main(): client = await Client.connect("localhost:7233") worker = Worker( client, task_queue="my-task-queue", workflows=[MyWorkflow], activities=[my_activity], ) await worker.run() ``` ## Workflow Definition ```python from temporalio import workflow from datetime import timedelta @workflow.defn class MyWorkflow: @workflow.run async def run(self, name: str) -> str: """Workflow run method""" # Execute activity result = await workflow.execute_activity( my_activity, name, start_to_close_timeout=timedelta(seconds=30), ) return f"Hello {result}" ``` ## Activity Implementation ```python from temporalio import activity @activity.defn async def my_activity(name: str) -> str: """Activity - can fail and retry""" # Do work (database, API, etc.) return name.upper() ``` ## Starting Workflows ```python from temporalio.client import Client async def start_workflow(): client = await Client.connect("localhost:7233") handle = await client.start_workflow( MyWorkflow.run, "World", id="my-workflow-id", task_queue="my-task-queue", ) result = await handle.result() print(res...