in src/dma/collector/query_managers/postgres.py [0:0]
def get_per_db_collection_queries(self) -> set[str]:
if self.db_version is None:
msg = "Database Version was not set. Ensure the initialization step complete successfully."
raise ApplicationError(msg)
get_db_major_version(self.db_version)
return {
"collection_postgres_extensions",
"collection_postgres_pglogical_provider_node",
"collection_postgres_pglogical_privileges",
"collection_postgres_pglogical_schema_usage_privilege",
"collection_postgres_user_schemas_without_privilege",
"collection_postgres_user_tables_without_privilege",
"collection_postgres_user_views_without_privilege",
"collection_postgres_user_sequences_without_privilege",
"collection_postgres_tables_with_no_primary_key",
"collection_postgres_tables_with_primary_key_replica_identity",
}