code: def wait():
      global _async
      for op in _async:
          op.wait()
      _async = []
  
      torch.cuda.synchronize()
  
file_path: H2O/h2o_flexgen/benchmark/third_party/DeepSpeed/deepspeed/runtime/pipe/p2p.py
imports: import pickle
  import typing
  import torch
  from deepspeed import comm
  from packaging.version import Version
  from deepspeed.git_version_info import torch_info
label_desc: Use image node_id 6 for calling a global function with example usage: wait() without return types