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
-
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: k8s.V1Pod) → k8s.V1Pod[source]
-
Adds sidecar