code: def run(self):
      try:
          self.getLogger().info("Started running")
          # Get the instruments and bars.
          instruments, bars = self.getInstrumentsAndBars()
          barsFreq = self.getBarsFrequency()
  
          # Process jobs
          job = self.getNextJob()
          while job is not None:
              self.__processJob(job, barsFreq, instruments, bars)
              job = self.getNextJob()
          self.getLogger().info("Finished running")
      except Exception as e:
          self.getLogger().exception(
              "Finished running with errors: %s" % (e)
          )
  
imports: import socket
  import multiprocessing
  import retrying
  from six.moves import xmlrpc_client
  import pyalgotrade.logger
  from pyalgotrade import barfeed
  from pyalgotrade.optimizer import serialization
label_desc: Use image node_id 9 for calling the Worker obj's underlying member method code with example usage: obj.run() without return types