def get_collection_queries()

in src/dma/collector/query_managers/postgres.py [0:0]

• 29 lines of code
• 5 McCabe index (conditional complexity)

    def get_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)
        major_version = get_db_major_version(self.db_version)
        version_prefix = "base" if major_version > 13 else "13" if major_version == 13 else "12"
        bg_writer_stats = (
            "collection_postgres_bg_writer_stats"
            if major_version < 17
            else "collection_postgres_bg_writer_stats_from_pg17"
        )
        return {
            f"collection_postgres_{version_prefix}_table_details",
            f"collection_postgres_{version_prefix}_database_details",
            f"collection_postgres_{version_prefix}_replication_slots",
            "collection_postgres_applications",
            "collection_postgres_aws_extension_dependency",
            "collection_postgres_aws_oracle_exists",
            bg_writer_stats,
            "collection_postgres_calculated_metrics",
            "collection_postgres_data_types",
            "collection_postgres_index_details",
            "collection_postgres_replication_stats",
            "collection_postgres_schema_details",
            "collection_postgres_schema_objects",
            "collection_postgres_settings",
            "collection_postgres_source_details",
            "collection_postgres_replication_role",
        }