code: def __init__(self) -> None:
      config.load_kube_config()
      self.v1 = client.AppsV1Api()
      self._scale_master(up=True)
  
      # Verify we have pulled our image.
      # TODO this won't work if we have multiple nodes.
      wait_for_command_state(run_command(0, slots=0), "TERMINATED", 300)
      wait_for_command_state(run_command(0, slots=1), "TERMINATED", 300)
  
file_path: determined/e2e_tests/tests/cluster/managed_cluster_k8s.py
imports: import time
  from typing import Iterator
  import pytest
  from kubernetes import client, config, watch
  from tests import config
  from .abstract_cluster import Cluster
  from .managed_cluster import get_agent_data
  from .test_groups import det_cmd
  from .utils import run_command, wait_for_command_state
label_desc: Use image node_id 1 to create a new ManagedK8sCluster object from inherited base classes: Cluster with example: obj = ManagedK8sCluster()