airflow.providers.docker.decorators.docker
¶
Module Contents¶
Functions¶
|
Python operator decorator; wraps a function into an Airflow operator. |
- airflow.providers.docker.decorators.docker.docker_task(python_callable=None, multiple_outputs=None, **kwargs)[source]¶
Python operator decorator; wraps a function into an Airflow operator.
Also accepts any argument that DockerOperator will via
kwargs
. Can be reused in a single DAG.- Parameters
python_callable (Callable | None) – Function to decorate
multiple_outputs (bool | None) – If set, function return value will be unrolled to multiple XCom values. Dict will unroll to XCom values with keys as XCom keys. Defaults to False.