code: def __init__(self, abort_impl, experiment):
      super(AbortMessageProcessor, self).__init__()
      self._abort_impl = abort_impl
      self._experiment = experiment
      self.received_abort_message = False
  
file_path: neptune-client/src/neptune/legacy/internal/threads/aborting_thread.py
imports: import threading
  from websocket import WebSocketConnectionClosedException
  from neptune.legacy.internal.threads.neptune_thread import NeptuneThread
  from neptune.legacy.internal.websockets.message import MessageType
  from neptune.legacy.internal.websockets.websocket_message_processor import WebsocketMessageProcessor
label_desc: Use image node_id 1 to create a new AbortMessageProcessor object from inherited base classes: WebsocketMessageProcessor with example: obj = AbortMessageProcessor(abort_impl, experiment)