Function run

misc/python/materialize/cli/orchestratord.py:102–132

(args: argparse.Namespace)

def run(args: argparse.Namespace):
    acquire(
        "orchestratord",
        dev=args.dev,
        cluster=args.kind_cluster_name,
    )

    try:
        subprocess.check_output(
            ["helm", "status", "orchestratord", f"--namespace={args.namespace}"]
        )
        command = "upgrade"
    except:
        command = "install"

    helm_args = [
        "helm",
        command,
        "orchestratord",
        "misc/helm-charts/operator",
        "--atomic",
        f"--set=operator.image.tag={DEV_IMAGE_TAG}",
        f"--set=operator.image.repository={image_registry()}/orchestratord",
        "--create-namespace",
        f"--namespace={args.namespace}",
    ]
    if args.values is not None:
        helm_args.extend(["--values", args.values])
    if args.set is not None:
        helm_args.extend([f"--set={v}" for v in args.set])
    subprocess.check_call(helm_args)


def reset(args: argparse.Namespace):