This module handles all xcom functionality for the KubernetesPodOperator
by attaching a sidecar container that blocks the pod from completing until
Airflow has pulled result data into the worker for xcom serialization.
Module Contents
Functions
-
class airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults[source]
Static defaults for Pods
-
XCOM_MOUNT_PATH = '/airflow/xcom'[source]
-
SIDECAR_CONTAINER_NAME = 'airflow-xcom-sidecar'[source]
-
XCOM_CMD = 'trap "exit 0" INT; while true; do sleep 1; done;'[source]
-
VOLUME_MOUNT[source]
-
VOLUME[source]
-
SIDECAR_CONTAINER[source]
-
airflow.providers.cncf.kubernetes.utils.xcom_sidecar.add_xcom_sidecar(pod, *, sidecar_container_image=None, sidecar_container_resources=None)[source]
Adds sidecar
