code: def test(self, distributed_fixture, class_tmpdir, val1, val2):
      for rank in range(2):
          file_path = os.path.join(
              class_tmpdir, f"checkpoint-{rank}.pt"
          )
          with open(file_path, "r") as f:
              chkpt = f.read()
          assert chkpt == f"{rank},{val1},{val2}"
      assert int(os.environ["WORLD_SIZE"]) == 1
  
imports: import os
  import torch
  import deepspeed.comm
  import deepspeed
  from unit.common import DistributedTest, DistributedFixture, get_master_port
  from unit.simple_model import SimpleModel
  from deepspeed.accelerator import get_accelerator
  import pytest
  from deepspeed.ops.op_builder import FusedAdamBuilder
label_desc: Use image node_id 1 for calling the TestDistributedFixture obj's underlying member method code with example usage: obj.test(distributed_fixture, class_tmpdir, val1, val2) without return types