airflow.models.taskmap
¶
Table to store information about mapped task instances (AIP-42).
Module Contents¶
Classes¶
Task map variant. |
|
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).
- 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.