Materialize/misc/python/materialize/cloudtest/util/print_pods.py

# Copyright Materialize, Inc. and contributors. All rights reserved.
#
# Use of this software is governed by the Business Source License
# included in the LICENSE file at the root of this repository.
#
# As of the Change Date specified in that file, in accordance with
# the Business Source License, use of this software will be governed
# by the Apache License, Version 2.0.


import subprocess

from materialize.cloudtest import DEFAULT_K8S_CONTEXT_NAME


def print_pods(
    context: str = DEFAULT_K8S_CONTEXT_NAME,
    label: str | None = None,
) -> None:
    cmd = [
        "kubectl",
        "get",
        "pods",
        "--context",
        context,
    ]

    if label is not None:
        cmd.extend(["--selector", label])

    try:
        print("Pods are:")
        subprocess.run(cmd)
    except subprocess.CalledProcessError as e:
        print(e, e.output)