code: def __init__(self, worker_address: str, subtask_processor_cls: Type):
      # specify subtask process class
      # for test purpose
      self._worker_address = worker_address
      self._subtask_processor_cls = subtask_processor_cls
      self._cluster_api = None
  
      self._band_slot_runner_refs = dict()
  
file_path: mars/mars/services/subtask/worker/manager.py
imports: import asyncio
  from typing import Type
  from ....None import oscar
  from ....oscar.backends.allocate_strategy import IdleLabel
  from .runner import SubtaskRunnerActor
label_desc: Use image node_id 1 to create a new SubtaskRunnerManagerActor object from inherited base classes: mo with example: obj = SubtaskRunnerManagerActor(worker_address, subtask_processor_cls)