code: def _check_cancelling(cls, subtask_info: SubtaskExecutionInfo):
      if subtask_info.cancelling:
          raise asyncio.CancelledError
  
imports: import asyncio
  import functools
  import logging
  import operator
  import pprint
  import sys
  from collections import defaultdict
  from dataclasses import dataclass, field
  from typing import Dict, Optional
  from ....None import oscar
  from ....core import ExecutionError
  from ....core.graph import DAG
  from ....core.operand import Fetch, FetchShuffle
  from ....lib.aio import alru_cache
  from ....metrics import Metrics
  from ....oscar.errors import MarsError
  from ....storage import StorageLevel
  from ....utils import dataslots, get_chunk_key_to_data_keys, wrap_exception
  from ...cluster import ClusterAPI
  from ...meta import MetaAPI
  from ...storage import StorageAPI
  from ...subtask import Subtask, SubtaskAPI, SubtaskResult, SubtaskStatus
  from .workerslot import BandSlotManagerActor
  from .quota import QuotaActor
label_desc: Use image node_id 3 for calling the SubtaskExecutionActor obj's underlying member method code with example usage: obj._check_cancelling(cls, subtask_info) without return types