code: def _consume_constraint(
      self,
      microbatch_id: int,
      forward_only: bool,
      input_pp_ranks: List[int],
      output_pp_ranks: List[int],
      ret_future,
  ):
      pass
  
imports: import threading
  from typing import Callable, Dict, List
  import torch
  from torch._C._distributed_rpc import PyRRef
  from torch.futures import Future
  from colossalai.legacy.pipeline.pipeline_process_group import ppg
  from colossalai.legacy.pipeline.rpc._pipeline_base import Phase, PipelineEngineBase, UniqueKey, WorkerBase, WorkItem
label_desc: Use image node_id 2 for calling the ChimeraPipelineEngine obj's underlying member method code with example usage: obj._consume_constraint(microbatch_id, forward_only, input_pp_ranks, output_pp_ranks, ret_future) without return types