airflow.models.taskinstancekey¶

Module Contents¶

Classes¶

TaskInstanceKey

Key used to identify task instance.
class airflow.models.taskinstancekey.TaskInstanceKey[source]¶

Bases: NamedTuple

Key used to identify task instance.

property primary: tuple[str, str, str, int][source]¶

Return task instance primary key part of the key.

property reduced: TaskInstanceKey[source]¶

Remake the key by subtracting 1 from try number to match in memory information.

property key: TaskInstanceKey[source]¶

For API-compatibly with TaskInstance.

Returns self

dag_id: str[source]¶
task_id: str[source]¶
run_id: str[source]¶
try_number: int = 1[source]¶
map_index: int[source]¶
with_try_number(try_number)[source]¶

Return TaskInstanceKey with provided try_number.

Was this entry helpful?