code: def run(self):
      if six.PY3:
          asyncio.set_event_loop_policy(
              tornado.platform.asyncio.AnyThreadEventLoopPolicy()
          )
  
imports: import json
  import time
  import threading
  import six
  from ws4py.client import tornadoclient
  import tornado
  import pyalgotrade.logger
label_desc: Use image node_id 1 for calling the WebSocketClientThreadBase obj's underlying member method code with example usage: obj.run() without return types