airflow.models.expandinput

Module Contents

Classes

DictOfListsExpandInput

Storage type of a mapped operator's mapped kwargs.

ListOfDictsExpandInput

Storage type of a mapped operator's mapped kwargs.

Functions

get_mappable_types()

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]
airflow.models.expandinput.get_mappable_types()[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]
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]
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?