Josh Purtell
12/23/2024, 3:02 AMNate
12/23/2024, 6:30 PMIn [5]: from prefect import flow, pause_flow_run
In [6]: from prefect.exceptions import FlowPauseTimeout
In [7]: @flow
...: def f():
...: try:
...: pause_flow_run(timeout=3)
...: except FlowPauseTimeout:
...: print('its fine')
...:
In [8]: f()
12:30:09.636 | INFO | prefect.engine - Created flow run 'rugged-jaguarundi' for flow 'f'
12:30:09.929 | INFO | Flow run 'rugged-jaguarundi' - Pausing flow, execution will continue when this flow run is resumed.
its fine
12:30:14.046 | INFO | Flow run 'rugged-jaguarundi' - Finished in state Completed()