Tools

depeche_db.tools.DbSubscriptionStateProvider(name, engine)

Bases: SubscriptionStateProvider

get_migration_ddl(name) classmethod

DDL Script to migrate from <=0.8.0

initialize(subscription_name)

Marks subscription state as initialized.

initialized(subscription_name)

Returns True if the subscription state was already initialized.

migrate_db_objects(name, conn) classmethod

Migrate from <=0.8.0

---

depeche_db.tools.DbLockProvider(name, engine)

---

depeche_db.tools.PydanticMessageSerializer(message_type, aliases=None)

Bases: MessageSerializer[T]