astronomer.providers.amazon.aws.xcom_backends.s3

Classes

S3XComBackend

The S3 custom xcom backend is an xcom custom backend wrapper that handles

Module Contents

class astronomer.providers.amazon.aws.xcom_backends.s3.S3XComBackend(context=None)

Bases: airflow.models.xcom.BaseXCom

The S3 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 S3 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.