code: def __init__(
      self,
      *,
      session: api.Session,
      trial_id: int,
      task_id: str,
      distributed: Optional[core.DistributedContext] = None,
  ) -> None:
      self._session = session
      self._trial_id = trial_id
      self._task_id = task_id
      self._distributed = distributed
  
imports: import atexit
  import collections
  import datetime
  import logging
  import queue
  import sys
  import threading
  import time
  import types
  from typing import Any, Callable, Dict, Iterator, List, Optional, TextIO, Union
  from determined import core
  from determined.common import api
label_desc: Use image node_id 1 to create a new _LogShipper object  with example: obj = _LogShipper()