code: def test_concurrent_pipelines(device):
      test_data_path = os.path.join(
          get_dali_extra_path(), "db/single/fits/compressed/"
      )
  
      pipelines = []
      for _ in range(5):
          pipeline = FitsReaderPipeline(
              test_data_path,
              device=device,
              device_id=0,
              num_threads=4,
              batch_size=1,
          )
          pipeline.build()
          pipelines.append(pipeline)
  
      for _ in range(3):
          expected_output = None
          for p in pipelines:
              pipeline_output = p.run()
              if expected_output is None:
                  expected_output = pipeline_output
              else:
                  assert np.all(
                      pipeline_output[0].as_array()
                      == expected_output[0].as_array()
                  )
  
imports: import itertools
  import os
  import sys
  from nvidia.dali import pipeline_def
  import nvidia.dali.fn
  from astropy.io import fits
  import numpy
  import tempfile
  import random
  from nose2.tools import params
  from test_utils import to_array, get_dali_extra_path
  from numpy.testing import assert_array_equal
label_desc: Use image node_id 8 for calling a global function with example usage: test_concurrent_pipelines(device) without return types