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
compute_transaction_key
handle_rollback
is_cancelled
is_running
log_finished_message
record_terminal_state_timing
state
SyncTaskRunEngine
asset_context
begin_run
call_hooks
call_task_fn
can_retry
client
handle_crash
handle_exception
handle_retry
handle_success
handle_timeout
initialize_run
result
run_context
set_state
setup_run_context
start
transaction_context
wait_until_ready
AsyncTaskRunEngine
asset_context
begin_run
call_hooks
call_task_fn
can_retry
client
handle_crash
handle_exception
handle_retry
handle_success
handle_timeout
initialize_run
result
run_context
set_state
setup_run_context
start
transaction_context
wait_until_ready