airflow.providers.cncf.kubernetes.utils.xcom_sidecar

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

Classes

PodDefaults

Static defaults for Pods

Functions

add_xcom_sidecar(pod)

Adds sidecar

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)[source]

Adds sidecar

Was this entry helpful?