Class●Since v1.0

BasePostgresSaver

BasePostgresSaver()

Bases

BaseCheckpointSaver[str]

Attributes

SELECT_SQL: SELECT_SQL

SELECT_PENDING_SENDS_SQL: SELECT_PENDING_SENDS_SQL

MIGRATIONS: MIGRATIONS

UPSERT_CHECKPOINT_BLOBS_SQL: UPSERT_CHECKPOINT_BLOBS_SQL

UPSERT_CHECKPOINTS_SQL: UPSERT_CHECKPOINTS_SQL

UPSERT_CHECKPOINT_WRITES_SQL: UPSERT_CHECKPOINT_WRITES_SQL

INSERT_CHECKPOINT_WRITES_SQL: INSERT_CHECKPOINT_WRITES_SQL

supports_pipeline: bool

Methods

get_next_version

View source on GitHub