prefect.task_runs
TaskRunWaiter
TaskRunWaiter.wait_for_task_run
with the task run ID to wait for. The method
will return when the task run has finished or the timeout has elapsed.
The service will automatically stop when the Python process exits or when the
global loop thread is stopped.
Example:
start
stop
wait_for_task_run
task_run_id
: The ID of the task run to wait for.timeout
: The maximum time to wait for the task run to
finish. Defaults to None.add_done_callback
task_run_id
: The ID of the task run to wait for.callback
: The callback to call when the task run finishes.instance