airflow.models.expandinput¶

Module Contents¶

Classes¶

MappedArgument

Stand-in stub for task-group-mapping arguments.

DictOfListsExpandInput

Storage type of a mapped operator's mapped kwargs.

ListOfDictsExpandInput

Storage type of a mapped operator's mapped kwargs.

Functions¶

is_mappable(v)

get_map_type_key(expand_input)

create_expand_input(kind, value)

Attributes¶

ExpandInput

OperatorExpandArgument

OperatorExpandKwargsArgument

EXPAND_INPUT_EMPTY

airflow.models.expandinput.ExpandInput[source]¶
airflow.models.expandinput.OperatorExpandArgument[source]¶
airflow.models.expandinput.OperatorExpandKwargsArgument[source]¶
class airflow.models.expandinput.MappedArgument[source]¶

Bases: airflow.utils.mixins.ResolveMixin

Stand-in stub for task-group-mapping arguments.

This is very similar to an XComArg, but resolved differently. Declared here (instead of in the task group module) to avoid import cycles.

abstract get_task_map_length(run_id, *, session)[source]¶
iter_references()[source]¶

Find underlying XCom references this contains.

This is used by the DAG parser to recursively find task dependencies.

resolve(context, *, session=NEW_SESSION)[source]¶

Resolve this value for runtime.

airflow.models.expandinput.is_mappable(v)[source]¶
exception airflow.models.expandinput.NotFullyPopulated(missing)[source]¶

Bases: RuntimeError

Raise when get_map_lengths cannot populate all mapping metadata.

This is generally due to not all upstream tasks have finished when the function is called.

__str__()[source]¶

Return str(self).

class airflow.models.expandinput.DictOfListsExpandInput[source]¶

Bases: NamedTuple

Storage type of a mapped operator’s mapped kwargs.

This is created from expand(**kwargs).

value: dict[str, OperatorExpandArgument][source]¶
get_parse_time_mapped_ti_count()[source]¶
get_total_map_length(run_id, *, session)[source]¶
iter_references()[source]¶
resolve(context, session)[source]¶
class airflow.models.expandinput.ListOfDictsExpandInput[source]¶

Bases: NamedTuple

Storage type of a mapped operator’s mapped kwargs.

This is created from expand_kwargs(xcom_arg).

value: OperatorExpandKwargsArgument[source]¶
get_parse_time_mapped_ti_count()[source]¶
get_total_map_length(run_id, *, session)[source]¶
iter_references()[source]¶
resolve(context, session)[source]¶
airflow.models.expandinput.EXPAND_INPUT_EMPTY[source]¶
airflow.models.expandinput.get_map_type_key(expand_input)[source]¶
airflow.models.expandinput.create_expand_input(kind, value)[source]¶

Was this entry helpful?