Skip to content

Latest commit

 

History

History
42 lines (30 loc) · 1.02 KB

README.md

File metadata and controls

42 lines (30 loc) · 1.02 KB

Updatable Timer Sample

Demonstrates a helper class which relies on workflow.wait_condition to implement a blocking sleep that can be updated at any moment.

The sample is composed of the three executables:

  • worker.py hosts the Workflow Executions.
  • starter.py starts Workflow Executions.
  • wake_up_timer_updater.py Signals the Workflow Execution with the new time to wake up.

First start the Worker:

uv run updatable_timer/worker.py

Check the output of the Worker window. The expected output is:

Worker started, ctrl+c to exit

Then in a different terminal window start the Workflow Execution:

uv run updatable_timer/starter.py

Check the output of the Worker window. The expected output is:

Workflow started: run_id=...

Then run the updater as many times as you want to change timer to 10 seconds from now:

uv run updatable_timer/wake_up_time_updater.py

Check the output of the worker window. The expected output is:

Updated wake up time to 10 seconds from now