`airflow.models.expandinput`¶

Module Contents¶

`DictOfListsExpandInput`	Storage type of a mapped operator's mapped kwargs.
`ListOfDictsExpandInput`	Storage type of a mapped operator's mapped kwargs.

`get_mappable_types`()
`get_map_type_key`(expand_input)
`create_expand_input`(kind, value)

`ExpandInput`
`OperatorExpandArgument`
`OperatorExpandKwargsArgument`
`EXPAND_INPUT_EMPTY`

airflow.models.expandinput.get_mappable_types()[source]¶

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

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.

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).

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).

get_parse_time_mapped_ti_count()[source]¶

get_total_map_length(run_id, *, session)[source]¶

resolve(context, session)[source]¶

airflow.models.expandinput.get_map_type_key(expand_input)[source]¶

airflow.models.expandinput.create_expand_input(kind, value)[source]¶