code: def create_pipeline(creator, batch_size, num_gpus):
      iters = 0
      # make sure that data size and batch are not divisible
      while iters % batch_size == 0:
          while iters != 0 and iters % batch_size == 0:
              batch_size += 1
  
          pipes = [creator(gpu) for gpu in range(num_gpus)]
          [pipe.build() for pipe in pipes]
          iters = pipes[0].epoch_size("Reader")
          iters = iters // num_gpus
      return pipes, iters
  
imports: import nose_utils
  import math
  from nvidia.dali.pipeline import Pipeline
  import nvidia.dali.ops
  import numpy
  import os
  from test_utils import get_dali_extra_path
label_desc: Use image node_id 8 for calling a global function with example usage: create_pipeline(creator, batch_size, num_gpus) and returns: pipes,  iters