prefect.task_engine
run_task_sync
run_task_async
run_generator_task_sync
run_generator_task_async
run_task
task
: The task to runtask_run_id
: The ID of the task run; if not provided, a new task run
will be createdtask_run
: The task run object; if not provided, a new task run
will be createdparameters
: The parameters to pass to the taskwait_for
: A list of futures to wait for before running the taskreturn_type
: The return type to return; either “state” or “result”dependencies
: A dictionary of task run inputs to use for dependency trackingcontext
: A dictionary containing the context to use for the task run; only
required if the task is running on in a remote environmentTaskRunTimeoutError
BaseTaskRunEngine
state
is_cancelled
compute_transaction_key
record_terminal_state_timing
is_running
log_finished_message
handle_rollback
SyncTaskRunEngine
client
can_retry
call_hooks
begin_run
set_state
result
handle_success
handle_retry
handle_exception
handle_timeout
handle_crash
setup_run_context
asset_context
initialize_run
wait_until_ready
start
transaction_context
run_context
call_task_fn
AsyncTaskRunEngine
client
can_retry
call_hooks
begin_run
set_state
result
handle_success
handle_retry
handle_exception
handle_timeout
handle_crash
setup_run_context
asset_context
initialize_run
wait_until_ready
start
transaction_context
run_context
call_task_fn