code: def run(self):
      super(WebSocketClientThread, self).run()
  
      # We need to build the WebSocketClient right in the thread since it has thread affinity.
      self.__wsclient = WebSocketClient()
      self.__wsclient.connect()
      self.__wsclient.startClient()
  
imports: import unittest
  import threading
  import datetime
  from pyalgotrade.websocket import pusher
  from pyalgotrade.websocket import client
label_desc: Use image node_id 2 for calling the WebSocketClientThread obj's underlying member method code with example usage: obj.run() without return types