code: def _schedule_done(self):
      self._done.set()
  
imports: import asyncio
  import itertools
  import logging
  import time
  from collections import defaultdict
  from typing import Dict, List
  from .....None import oscar
  from .....core import ChunkGraph, Chunk
  from .....core.operand import Fuse, Fetch
  from .....metrics import Metrics
  from .....utils import get_chunk_params
  from .....typing import BandType, TileableType
  from ....meta import MetaAPI, WorkerMetaAPI
  from ....scheduling import SchedulingAPI
  from ....subtask import Subtask, SubtaskGraph, SubtaskResult, SubtaskStatus
  from ....task.core import Task, TaskResult, TaskStatus
  from ..api import ExecutionChunkResult
label_desc: Use image node_id 3 for calling the TaskStageProcessor obj's underlying member method code with example usage: obj._schedule_done() without return types