code: def test_reproducibility(self) -> None:
      def controller_fn(
          workloads: workload.Stream,
      ) -> determined.TrialController:
          return utils.make_trial_controller_from_trial_implementation(
              trial_class=deepspeed_linear_model.LinearPipelineEngineTrial,
              hparams=self.hparams,
              workloads=workloads,
              trial_seed=self.trial_seed,
              expose_gpus=True,
          )
  
      utils.reproducibility_test(
          controller_fn, steps=1000, validation_freq=100
      )
  
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 21 for calling the TestDeepSpeedTrial obj's underlying member method code with example usage: obj.test_reproducibility() and returns: utils