Method run

misc/python/materialize/cli/mzcompose.py:464–628

(self, args: argparse.Namespace)

        )

    def run(self, args: argparse.Namespace) -> None:
        composition = load_composition(args)

        service = composition.compose["services"].get(args.service)
        if not service:
            raise UIError(f"unknown service {args.service!r}")

        # Attempting to load the default port will produce a nice error message
        # if the service isn't running or isn't exposing a port.
        composition.default_port(args.service)

        image = service["image"].rsplit(":", 1)[0]
        ghcr_prefix = "ghcr.io/materializeinc/"
        if image.startswith(ghcr_prefix):
            image = image.removeprefix(ghcr_prefix)

        if image == "materialize/materialized":
            deps = composition.repo.resolve_dependencies(
                [composition.repo.images["psql"]]
            )
            deps.acquire()
            if args.mz_system:
                deps["psql"].run(
                    [
                        "-h",
                        service.get("hostname", args.service),
                        "-p",
                        "6877",
                        "-U",
                        "mz_system",
                        "materialize",
                    ],
                    docker_args=[
                        "--interactive",
                        f"--network={composition.project_name}_default",
                    ],
                    env={"PGPASSWORD": "materialize", "PGCLIENTENCODING": "utf-8"},
                )
            else:
                deps["psql"].run(
                    [
                        "-h",
                        service.get("hostname", args.service),
                        "-p",
                        "6875",
                        "-U",
                        "materialize",
                        "materialize",
                    ],
                    docker_args=[
                        "--interactive",
                        f"--network={composition.project_name}_default",
                    ],
                    env={"PGCLIENTENCODING": "utf-8"},
                )
        elif image == "materialize/balancerd":
            assert not args.mz_system
            deps = composition.repo.resolve_dependencies(