airflow.models.taskmap

Table to store information about mapped task instances (AIP-42).

Module Contents

Classes

TaskMapVariant

Task map variant.

TaskMap

Model to track dynamic task-mapping information.
class airflow.models.taskmap.TaskMapVariant[source]

Bases: enum.Enum

Task map variant.

Possible values are dict (for a key-value mapping) and list (for an ordered value sequence).

DICT = dict[source]
LIST = list[source]
class airflow.models.taskmap.TaskMap(dag_id, task_id, run_id, map_index, length, keys)[source]

Bases: airflow.models.base.Base

Model to track dynamic task-mapping information.

This is currently only populated by an upstream TaskInstance pushing an XCom that's pulled by a downstream for mapping purposes.

__tablename__ = task_map[source]
dag_id[source]
task_id[source]
run_id[source]
map_index[source]
length[source]
keys[source]
__table_args__[source]
classmethod from_task_instance_xcom(cls, ti, value)[source]
property variant(self)[source]

Was this entry helpful?