def _check_version()

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

• 21 lines of code
• 4 McCabe index (conditional complexity)

    def _check_version(self) -> None:
        rule_code = "DATABASE_VERSION"

        detected_major_version = get_db_major_version(self.db_version)
        for c in self.rule_config:
            if (
                detected_major_version not in c.db_version_map
                or detected_major_version < c.minimum_supported_major_version
            ):
                self.save_rule_result(
                    c.db_variant,
                    rule_code,
                    "ERROR",
                    f"Replication from source database server ({self.db_version}) is not supported",
                )
            else:
                self.save_rule_result(
                    c.db_variant,
                    rule_code,
                    "PASS",
                    f"Version {self.db_version} is supported.  Please ensure that you selected a version that meets or exceeds version {detected_major_version!s}.",
                )