Function environment

misc/python/materialize/cli/orchestratord.py:189–327

(args: argparse.Namespace)

def environment(args: argparse.Namespace):
    env_kubectl = make_env_kubectl(args)

    if args.environmentd_version:
        image_tag = args.environmentd_version
    else:
        for image in ["environmentd", "clusterd", "balancerd", "console"]:
            acquire(
                image,
                dev=args.dev,
                cluster=args.kind_cluster_name,
            )
        image_tag = DEV_IMAGE_TAG
    environmentd_image_ref = f"{image_registry()}/environmentd:{image_tag}"

    try:
        kubectl(
            "get",
            "namespace",
            args.namespace,
            cluster=args.kind_cluster_name,
        )
    except subprocess.CalledProcessError:
        kubectl(
            "create",
            "namespace",
            args.namespace,
            cluster=args.kind_cluster_name,
        )

    if args.environment_id is None:
        environment_id = str(uuid4())
    else:
        environment_id = args.environment_id

    def root_psql(cmd: str):
        env_kubectl(
            "run",
            "psql-setup",
            "--labels=app=environmentd",
            "--image=postgres",
            "--command=true",
            "--restart=Never",
            "--attach=true",
            "--rm=true",
            "--",
            "psql",
            args.postgres_url,
            "-c",
            cmd,
        )
        env_kubectl("wait", "--for=delete", "pod/psql-setup")

    pg_user = f"materialize_{environment_id}"
    pg_pass = "password"
    pg_db = f"materialize_{environment_id}"

    try: