code: def manual_init_distributed() -> Iterator[None]:
      """Set DET_MANUAL_INIT_DISTRIBUTED in os.environ for the duration of a single test."""
  
      os.environ["DET_MANUAL_INIT_DISTRIBUTED"] = "1"
      try:
          yield
      finally:
          del os.environ["DET_MANUAL_INIT_DISTRIBUTED"]
  
imports: import copy
  import json
  import os
  import pathlib
  from typing import Any, Dict, Iterator, Optional
  import pytest
  import torch
  from deepspeed.runtime import config_utils
  import determined
  import determined.pytorch.deepspeed
  from determined import workload
  from tests.experiment import utils
  from tests.experiment.fixtures import deepspeed_linear_model
label_desc: Use image node_id 1 for calling a global function with example usage: manual_init_distributed() without return types