code: def __init__(self, websocket_factory, abort_impl, experiment):
      super(AbortingThread, self).__init__(is_daemon=True)
      self._abort_message_processor = AbortMessageProcessor(
          abort_impl, experiment
      )
      self._ws_client = websocket_factory.create(
          shutdown_condition=threading.Event()
      )
  
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 AbortingThread object from inherited base classes: NeptuneThread with example: obj = AbortingThread(websocket_factory, abort_impl, experiment)