airflow.providers.docker.decorators.docker

Module Contents

Functions

docker_task(python_callable = None, multiple_outputs = None, **kwargs)

Python operator decorator. Wraps a function into an Airflow operator.

Attributes

T

airflow.providers.docker.decorators.docker.T[source]
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 (Optional[Callable]) -- Function to decorate

  • multiple_outputs (Optional[bool]) -- 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.

Was this entry helpful?