code: def __init__(
      self,
      band: BandType,
      worker_address: str,
      subtask_processor_cls: Type = None,
  ):
      self._band = band
      self._worker_address = worker_address
      self._subtask_processor_cls = self._get_subtask_processor_cls(
          subtask_processor_cls
      )
  
      self._cluster_api = None
  
      self._session_id_to_processors = dict()
      self._running_processor = None
      self._last_processor = None
  
file_path: mars/mars/services/subtask/worker/runner.py
imports: import asyncio
  import importlib
  import logging
  from typing import Dict, Optional, Type
  from ....None import oscar
  from ....lib.aio import alru_cache
  from ....typing import BandType
  from ...cluster import ClusterAPI
  from ..core import Subtask, SubtaskResult
  from ..errors import SlotOccupiedAlready
  from .processor import SubtaskProcessor, SubtaskProcessorActor
label_desc: Use image node_id 2 to create a new SubtaskRunnerActor object from inherited base classes: mo with example: obj = SubtaskRunnerActor(band, worker_address, subtask_processor_cls)