def _get_rds_logical_replication()

in src/dma/collector/workflows/readiness_check/_postgres/main.py [0:0]

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

    def _get_rds_logical_replication(self) -> str:
        rds_logical_replication_result = self.local_db.sql(
            "select c.setting_value from collection_postgres_settings c where c.setting_name='rds.logical_replication';"
        ).fetchone()
        return rds_logical_replication_result[0] if rds_logical_replication_result is not None else "unset"