def __init__(self, dashboard_agent):
    super().__init__(dashboard_agent)
    self._runtime_env_dir = dashboard_agent.runtime_env_dir
    self._logging_params = dashboard_agent.logging_params
    self._per_job_logger_cache = dict()
    self._env_cache: Dict[(str, CreatedEnvResult)] = dict()
    self._env_locks: Dict[(str, asyncio.Lock)] = dict()
    self._uris_to_envs: Dict[(str, Set[str])] = defaultdict(set)
    _initialize_internal_kv(self._dashboard_agent.gcs_client)
    assert _internal_kv_initialized()
    self._conda_manager = CondaManager(self._runtime_env_dir)
    self._py_modules_manager = PyModulesManager(self._runtime_env_dir)
    self._working_dir_manager = WorkingDirManager(self._runtime_env_dir)
    self._container_manager = ContainerManager(dashboard_agent.temp_dir)
def __init__(self, dashboard_agent):
    super().__init__(dashboard_agent)
    self._runtime_env_dir = dashboard_agent.runtime_env_dir
    self._logging_params = dashboard_agent.logging_params
    self._per_job_logger_cache = dict()
    self._env_cache: Dict[(str, CreatedEnvResult)] = dict()
    self._env_locks: Dict[(str, asyncio.Lock)] = dict()
    self._uris_to_envs: Dict[(str, Set[str])] = defaultdict(set)
    _initialize_internal_kv(self._dashboard_agent.gcs_client)
    assert _internal_kv_initialized()
    self._conda_manager = CondaManager(self._runtime_env_dir)
    self._py_modules_manager = PyModulesManager(self._runtime_env_dir)
    self._working_dir_manager = WorkingDirManager(self._runtime_env_dir)
    self._container_manager = ContainerManager(dashboard_agent.temp_dir)