code: def test_distributed_eval_stream_mode_max_exs(self):
      valid, test = self._distributed_train_model(
          task="integration_tests",
          num_epochs=0.01,
          datatype="train:stream",
          validation_max_exs=90,
          short_final_eval=True,
      )
  
      # Tests that StreamDialogData.get() is doing the right thing
      # Ensure no duplication of examples among workers
      # It would be 200 if each worker did all the examples
      # As in the test above:
      # It does 96 instead of 90 b/c there are two workers, told to do 45
      # each, and BatchWorld parley() does batchsize examples each time, so
      # each worker will do 49 examples.
      # In the future, if we fix VME, this assert should be changed to
      # exactly 90.
      self.assertEqual(valid["exs"].value(), 96)
      self.assertEqual(test["exs"].value(), 96)
  
imports: import os
  import unittest
  import parlai.utils.testing
  import parlai.scripts.build_dict
  import parlai.scripts.multiprocessing_train
  import parlai.tasks.integration_tests.agents
label_desc: Use image node_id 5 for calling the TestDistributed obj's underlying member method code with example usage: obj.test_distributed_eval_stream_mode_max_exs() without return types