temporalio_workflow_wait_condition_signal_quickstart.py

1from datetime import timedelta
2from temporalio import workflow
3
4@workflow.defn
5class MyWorkflow:
6    def __init__(self) -> None:
7        self._exit = False
8
9    @workflow.run
10    async def run(self) -> None:
11        # Wait for the _exit variable to become true
12        await workflow.wait_condition(lambda: self._exit)
13        
14    @workflow.signal
15    def exit_now(self) -> None:
16        self._exit = True