code: def __init__(self, logs_func: Callable[..., Any]) -> None:
      self._logs_process: Optional[multiprocessing.Process] = None
      self.logs_func = logs_func
  
file_path: determined/e2e_tests/tests/cluster_log_manager.py
imports: import multiprocessing
  from types import TracebackType
  from typing import Any, Callable, Optional
label_desc: Use image node_id 1 to create a new ClusterLogManager object  with example: obj = ClusterLogManager(logs_func)