code: def __init__(self):
      self._condition = threading.Condition()
      self._responses = collections.deque()
      self._open = True
  
imports: import collections
  import threading
  from aim.ext.transport.proto import health_pb2
  from aim.ext.transport.proto import health_pb2_grpc
label_desc: Use image node_id 1 to create a new _Watcher object  with example: obj = _Watcher()