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.

classmethod from_dict(dictionary)[source]

Create TaskInstanceKey from dictionary.

Was this entry helpful?