temporalio_hello_world_workflow_activity_worker_client.py

1import asyncio
2from datetime import timedelta
3from temporalio import workflow, activity
4from temporalio.client import Client
5from temporalio.worker import Worker
6
7# --- Workflow and Activity Definition ---
8
9@activity.defn
10async def say_hello(name: str) -> str:
11    return f"Hello, {name}!"
12
13@workflow.defn
14class SayHelloWorkflow:
15    @workflow.run
16    async def run(self, name: str) -> str:
17        return await workflow.execute_activity(
18            say_hello, name, start_to_close_timeout=timedelta(seconds=5)
19        )
20
21# --- Worker and Starter Execution ---
22
23async def main():
24    # Connect to the local Temporal server
25    client = await Client.connect("localhost:7233")
26
27    # Run the worker until interrupted
28    async with Worker(
29        client,
30        task_queue="hello-task-queue",
31        workflows=[SayHelloWorkflow],
32        activities=[say_hello],
33    ):
34        # Execute the workflow
35        result = await client.execute_workflow(
36            SayHelloWorkflow.run,
37            "Temporal",
38            id="hello-workflow-id",
39            task_queue="hello-task-queue",
40        )
41        print(f"Result: {result}")
42
43if __name__ == "__main__":
44    asyncio.run(main())