airflow.providers.cncf.kubernetes.decorators.kubernetes_cmd

Functions

kubernetes_cmd_task([python_callable])

Kubernetes cmd operator decorator.

Module Contents

airflow.providers.cncf.kubernetes.decorators.kubernetes_cmd.kubernetes_cmd_task(python_callable=None, **kwargs)[source]

Kubernetes cmd operator decorator.

This wraps a function which should return command to be executed in K8s using KubernetesPodOperator. The function should return a list of strings. If args_only is set to True, the function should return a list of arguments for container default command. Also accepts any argument that KubernetesPodOperator will via kwargs. Can be reused in a single DAG.

Parameters:

python_callable (collections.abc.Callable | None) – Function to decorate

Was this entry helpful?