code: def create(self, tag):
      log_dist(f"[Nebula] Start Checkpoint for tag:{tag}", ranks=[0])
      # -2 means: customer needs to  explicitly tell nebula
      # current checkpoint is complete by commit methond.
      self.checkpoint = torch_nebula.Checkpoint(tag, -2)
  
file_path: H2O/h2o_flexgen/benchmark/third_party/DeepSpeed/deepspeed/runtime/checkpoint_engine/nebula_checkpoint_engine.py
imports: import os
  import torch
  import torch_nebula
  from deepspeed.runtime.checkpoint_engine.checkpoint_engine import CheckpointEngine
  from deepspeed.utils import logger, log_dist
  from deepspeed.nebula.constants import *
label_desc: Use image node_id 2 for calling the NebulaCheckpointEngine obj's underlying member method code with example usage: obj.create(tag) without return types