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(ti, value)[source]¶
property variant[source]¶

Was this entry helpful?