airflow.models.operator

Module Contents

Functions

needs_expansion(task)

Whether a task needs expansion at runtime.

Attributes

Operator

airflow.models.operator.Operator[source]
airflow.models.operator.needs_expansion(task)[source]

Whether a task needs expansion at runtime.

A task needs expansion if it either

  • Is a mapped operator, or

  • Is in a mapped task group.

This is implemented as a free function (instead of a property) so we can make it a type guard.

Was this entry helpful?