Function validate

test/cloudtest/test_storage_shared_fate.py:95–120

(mz: MaterializeApplication, seed: int)

def validate(mz: MaterializeApplication, seed: int) -> None:
    validations = "\n".join(f"""
            > INSERT INTO t{i} SELECT 234000 + generate_series FROM generate_series(1, 1000);

            > SELECT COUNT(*) FROM source{i}_tbl;
            3000

            > SELECT * FROM v{i};
            3000

            > SELECT COUNT(*) FROM sink{i}_check_tbl;
            2000
    """ for i in range(NUM_SOURCES))

    mz.testdrive.run(
        input=dedent(f"""
            $ kafka-ingest key-format=bytes format=bytes key-terminator=: topic=storage-shared-fate repeat=1000
            EFG${{kafka-ingest.iteration}}:EFG${{kafka-ingest.iteration}}

            {validations}

            > DROP CLUSTER storage_shared_fate CASCADE;
            """),
        no_reset=True,
        seed=seed,
    )


def kill_clusterd(