code: def worker(self):
      # train tasks by other progress or machines for multiprocessing
      # FIXME: only can call after finishing simulation when using DelayTrainerRM, or there will be some exception.
      print("========== worker ==========")
      if isinstance(self.trainer, TrainerRM):
          self.trainer.worker()
      else:
          print(f"{type(self.trainer)} is not supported for worker.")
  
file_path: qlib/examples/online_srv/online_management_simulate.py
imports: from pprint import pprint
  import fire
  import qlib
  from qlib.model.trainer import DelayTrainerR, DelayTrainerRM, TrainerR, TrainerRM
  from qlib.workflow import R
  from qlib.workflow.online.manager import OnlineManager
  from qlib.workflow.online.strategy import RollingStrategy
  from qlib.workflow.task.gen import RollingGen
  from qlib.workflow.task.manage import TaskManager
  from qlib.tests.config import CSI100_RECORD_LGB_TASK_CONFIG_ONLINE, CSI100_RECORD_XGBOOST_TASK_CONFIG_ONLINE
  import pandas
  from qlib.contrib.evaluate import backtest_daily
  from qlib.contrib.evaluate import risk_analysis
  from qlib.contrib.strategy import TopkDropoutStrategy
label_desc: Use image node_id 4 for calling the OnlineSimulationExample obj's underlying member method code with example usage: obj.worker() without return types