temporalio_hello_world_workflow_with_activity_greeting.py

1import asyncio
2from datetime import timedelta
3from temporalio import activity, workflow
4from temporalio.client import Client
5from temporalio.worker import Worker
6
7# 1. Define the Activity
8@activity.defn
9async def say_hello(name: str) -> str:
10    return f"Hello, {name}!"
11
12# 2. Define the Workflow
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
21async def main():
22    # 3. Connect to a local Temporal server
23    client = await Client.connect("localhost:7233")
24
25    # 4. Run the worker
26    # In a real app, the worker and the starter would be in separate files.
27    async with Worker(
28        client,
29        task_queue="hello-world-task-queue",
30        workflows=[SayHelloWorkflow],
31        activities=[say_hello],
32    ):
33        # 5. Execute the workflow
34        result = await client.execute_workflow(
35            SayHelloWorkflow.run,
36            "Temporal",
37            id="hello-world-workflow-id",
38            task_queue="hello-world-task-queue",
39        )
40
41        print(f"Result: {result}")
42
43if __name__ == "__main__":
44    asyncio.run(main())