code: def __init__(self, *args, **kwargs):
      super().__init__(*args, **kwargs)
  
      check_options = dict()
      if self.subtask.extra_config:
          kwargs = self.subtask.extra_config.copy()
      else:
          kwargs = dict()
      self._operand_executors = operand_executors = kwargs.pop(
          "operand_executors", dict()
      )
      for op, executor in operand_executors.items():
          op.register_executor(executor)
      for key in _check_args:
          check_options[key] = kwargs.get(key, True)
      self._check_options = check_options
      self._check_keys = kwargs.get("check_keys")
      self._storage_api = CheckStorageAPI(self._storage_api)
  
file_path: mars/mars/services/subtask/worker/tests/subtask_processor.py
imports: from typing import Any, Dict
  from .....core import OperandType
  from .....tests.core import _check_args, ObjectCheckMixin
  from ...worker.processor import SubtaskProcessor
label_desc: Use image node_id 1 to create a new CheckedSubtaskProcessor object from inherited base classes: ObjectCheckMixin, SubtaskProcessor with example: obj = CheckedSubtaskProcessor()