blob: 5c83079e31c122b774c6340acae230d003d80786 [file] [log] [blame]
:py:mod:`airflow.providers.cncf.kubernetes.decorators.kubernetes`
=================================================================
.. py:module:: airflow.providers.cncf.kubernetes.decorators.kubernetes
Module Contents
---------------
Functions
~~~~~~~~~
.. autoapisummary::
airflow.providers.cncf.kubernetes.decorators.kubernetes.kubernetes_task
.. py:function:: kubernetes_task(python_callable = None, multiple_outputs = None, **kwargs)
Kubernetes operator decorator.
This wraps a function to be executed in K8s using KubernetesPodOperator.
Also accepts any argument that DockerOperator will via ``kwargs``. Can be
reused in a single DAG.
:param python_callable: Function to decorate
:param multiple_outputs: 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.