`airflow.models.taskreschedule`¶

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