Function version_check

test/cloud-canary/mzcompose.py:339–363

(c: Composition)

def version_check(c: Composition) -> None:
    print("Obtaining mz_version() string from local instance ...")
    c.up("materialized")
    # Remove the ($HASH) suffix because it can be different. The reason is that
    # the dockerhub devel-$HASH tag is just a link to the mzbuild-$CODEHASH. So
    # if the code has not changed, the environmentd image of the previous
    # version will be used.
    local_version = c.sql_query("SELECT mz_version();")[0][0].split(" ")[0]

    print("Obtaining mz_version() string from the cloud ...")
    cloud_cursor = psycopg.connect(
        host=c.cloud_hostname(),
        user=USERNAME,
        password=APP_PASSWORD,
        dbname="materialize",
        port=6875,
        sslmode="require",
    ).cursor()
    cloud_cursor.execute("SELECT mz_version()")
    result = cloud_cursor.fetchone()
    assert result is not None
    cloud_version = result[0].split(" ")[0]
    assert (
        local_version == cloud_version
    ), f"local version: {local_version} is not identical to cloud version: {cloud_version}"


def td(