code: def __init__(
      self, original_io: TextIO, handler: Callable[[str], None]
  ) -> None:
      self._original_io = original_io
      self._handler = handler
  
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 _Interceptor object  with example: obj = _Interceptor(original_io, handler)