astronomer.providers.google.cloud.xcom_backends.gcs

Module Contents

Classes

GCSXComBackend

The GCS custom xcom backend is an xcom custom backend wrapper that handles serialization and deserialization

class astronomer.providers.google.cloud.xcom_backends.gcs.GCSXComBackend(context=None)

Bases: airflow.models.xcom.BaseXCom

The GCS custom xcom backend is an xcom custom backend wrapper that handles serialization and deserialization of common data types. This overrides the TaskInstance.XCom object with this wrapper.

static serialize_value(value)

Custom XCOM for GCS to serialize the data

static deserialize_value(result)

Custom XCOM for GCS to deserialize the data

orm_deserialize_value()

Deserialize amethod which is used to reconstruct ORM XCom object. This method should be overridden in custom XCom backends to avoid unnecessary request or other resource consuming operations when creating XCom ORM model.