-
Notifications
You must be signed in to change notification settings - Fork 97
Expand file tree
/
Copy pathstart_activity.py
More file actions
31 lines (23 loc) · 1018 Bytes
/
start_activity.py
File metadata and controls
31 lines (23 loc) · 1018 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
import asyncio
from datetime import timedelta
from temporalio.client import Client
from temporalio.envconfig import ClientConfig
from hello_standalone_activity.my_activity import ComposeGreetingInput, compose_greeting
async def my_application():
connect_config = ClientConfig.load_client_connect_config()
connect_config.setdefault("target_host", "localhost:7233")
client = await Client.connect(**connect_config)
# Start the activity without waiting for the result
activity_handle = await client.start_activity(
compose_greeting,
args=[ComposeGreetingInput("Hello", "World")],
id="my-standalone-activity-id",
task_queue="my-standalone-activity-task-queue",
start_to_close_timeout=timedelta(seconds=10),
)
print(f"Started activity: {activity_handle.id}")
# Wait for the result
activity_result = await activity_handle.result()
print(f"Activity result: {activity_result}")
if __name__ == "__main__":
asyncio.run(my_application())