code: def run(self):
      try:
          super().run()
      except Exception:  # pragma: no cover
          _thread.interrupt_main()
          raise
  
imports: import _thread
  import json
  import logging
  import random
  import time
  import typing
  from redis import client
  from .None import exceptions, utils
label_desc: Use image node_id 1 for calling the PubSubWorkerThread obj's underlying member method code with example usage: obj.run() without return types