code: def do_test_worker(
      self, dispatchers: int, reuse_dataset: bool, round_robin: bool
  ):
      for processing_mode in ["distributed_epoch", "parallel_epochs"]:
          with self.subTest(
              processing_mode=processing_mode, dispatcher_side="compute"
          ):
              self.do_test_worker_compute_side(
                  dispatchers,
                  processing_mode=processing_mode,
                  reuse_dataset=reuse_dataset,
                  round_robin=round_robin,
              )
          with self.subTest(
              processing_mode=processing_mode,
              dispatcher_side="training",
          ):
              self.do_test_worker_training_side(
                  dispatchers,
                  processing_mode=processing_mode,
                  reuse_dataset=reuse_dataset,
                  round_robin=round_robin,
              )
  
file_path: horovod/test/parallel/test_compute_worker.py
imports: import logging
  import os
  import unittest
  from packaging import version
  from itertools import islice
  import tensorflow
  import horovod.tensorflow
  from horovod.runner.util.threads import in_thread
  from horovod.tensorflow.data.compute_service import TfDataServiceConfig, tf_data_service
  from horovod.tensorflow.data.compute_worker import main
label_desc: Use image node_id 6 for calling the ComputeWorkerTest obj's underlying member method code with example usage: obj.do_test_worker(dispatchers, reuse_dataset, round_robin) without return types