airflow.providers.standard.decorators.short_circuit¶

Functions¶

short_circuit_task([python_callable, multiple_outputs])

Wrap a function into an ShortCircuitOperator.

airflow.providers.standard.decorators.short_circuit.short_circuit_task(python_callable=None, multiple_outputs=None, **kwargs)[source]¶

Wrap a function into an ShortCircuitOperator.

Accepts kwargs for operator kwarg. Can be reused in a single DAG.

This function is only used only used during type checking or auto-completion.

Parameters:

python_callable (collections.abc.Callable | None) – Function to decorate
multiple_outputs (bool | None) – If set to True, the decorated function’s return value will be unrolled to multiple XCom values. Dict will unroll to XCom values with its keys as XCom keys. Defaults to False.