airflow.models.taskreschedule¶

TaskReschedule tracks rescheduled task instances.

Module Contents¶

class airflow.models.taskreschedule.TaskReschedule(task, execution_date, try_number, start_date, end_date, reschedule_date)[source]¶

Bases: airflow.models.base.Base

TaskReschedule tracks rescheduled task instances.

__tablename__ = task_reschedule[source]¶
id[source]¶
task_id[source]¶
dag_id[source]¶
execution_date[source]¶
try_number[source]¶
start_date[source]¶
end_date[source]¶
duration[source]¶
reschedule_date[source]¶
__table_args__[source]¶
static find_for_task_instance(task_instance, session)[source]¶

Returns all task reschedules for the task instance and try number, in ascending order.

Parameters

task_instance (airflow.models.TaskInstance) – the task instance to find task reschedules for

Was this entry helpful?