File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
examples/pydantic_ai_examples/temporal_streaming Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change 77import asyncio
88import os
99import uuid
10- from typing import Any , Union
10+ from typing import Any
1111
1212from temporalio .client import Client , WorkflowHandle
1313from temporalio .worker import Worker
@@ -28,9 +28,8 @@ async def poll_events(workflow_handle: WorkflowHandle[Any, str]) -> None:
2828 workflow_handle: Handle to the running workflow.
2929 """
3030 while True :
31- event : Union [EventStream , None ] = await workflow_handle .query ('event_stream' ,
32- result_type = Union [
33- EventStream , None ]) # type: ignore[misc]
31+ event : EventStream | None = await workflow_handle .query ('event_stream' ,
32+ result_type = EventStream | None ) # type: ignore[misc]
3433 if event is None :
3534 await asyncio .sleep (0.1 )
3635 continue
You can’t perform that action at this time.
0 commit comments