Function workflow_default

test/version-consistency/mzcompose.py:53–139

(c: Composition, parser: WorkflowArgumentParser)

def workflow_default(c: Composition, parser: WorkflowArgumentParser) -> None:
    c.down(destroy_volumes=True)

    test = VersionConsistencyTest()

    parser.add_argument(
        "--evaluation-strategy",
        default=EVALUATION_STRATEGY_NAME_DFR,
        type=str,
        choices=INTERNAL_EVALUATION_STRATEGY_NAMES,
    )

    parser.add_argument(
        "--other-tag",
        type=str,
        default="common-ancestor",
    )

    parser.add_argument(
        "--allow-same-version-comparison",
        action=argparse.BooleanOptionalAction,
        default=False,
    )

    parser.add_argument(
        "--query-output-mode",
        type=lambda mode: QueryOutputMode[mode.upper()],
        choices=QUERY_OUTPUT_MODE_CHOICES,
        default=QueryOutputMode.SELECT,
    )

    args = test.parse_output_consistency_input_args(parser)

    port_mz_default_internal, port_mz_system_internal = 6875, 6877
    port_mz_default_this, port_mz_system_this = 6875, 6877
    port_mz_default_other, port_mz_system_other = 16875, 16877
    tag_mz_other = resolve_tag(args.other_tag)

    print(f"Using {tag_mz_other} as tag for other mz version")

    with c.override(
        Materialized(
            name="mz_this",
            image=None,
            ports=[
                f"{port_mz_default_this}:{port_mz_default_internal}",
                f"{port_mz_system_this}:{port_mz_system_internal}",
            ],
            use_default_volumes=False,
        ),
        Materialized(
            name="mz_other",
            image=f"{image_registry()}/materialized:{tag_mz_other}",
            ports=[
                f"{port_mz_default_other}:{port_mz_default_internal}",
                f"{port_mz_system_other}:{port_mz_system_internal}",
            ],
            use_default_volumes=False,