code: def __init__(self, storage_api):
      self._storage_api = storage_api
      self._put_data_keys = set()
  
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 CheckStorageAPI object  with example: obj = CheckStorageAPI(storage_api)