_DockerDecoratedOperator

Docker

Wraps a Python callable and captures args/kwargs when called for execution.

View on GitHub

Last Updated: Nov. 11, 2021

Access Instructions

Install the Docker provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

python_callablepython callableA reference to an object that is callable
op_kwargsdicta dictionary of keyword arguments that will get unpacked in your function (templated)
op_argslista list of positional arguments that will get unpacked when calling your callable (templated)
multiple_outputsboolif set, function return value will be unrolled to multiple XCom values. Dict will unroll to xcom values with keys as keys. Defaults to False.

Documentation

Wraps a Python callable and captures args/kwargs when called for execution.

Was this page helpful?