code: def check_corrupted_videos(reader, wrong_video, msg):
      good_video = os.path.join(video_data_root, "cfr", "test_2.mp4")
      pipe = Pipeline(batch_size=BATCH_SIZE, num_threads=4, device_id=0)
      with pipe:
          vid = reader([wrong_video, good_video])
          pipe.set_outputs(vid)
      with check_output_pattern(pattern=msg):
          pipe.build()
          pipe.run()
  
imports: import os
  import math
  from test_utils import get_gpu_num
  from test_utils import get_dali_extra_path
  import nvidia.dali.ops
  import nvidia.dali.types
  from nvidia.dali.pipeline import Pipeline, pipeline_def
  import nvidia.dali.fn
  import numpy
  import tempfile
  from test_utils import check_output_pattern
  from nose_utils import assert_raises, raises
label_desc: Use image node_id 22 for calling a global function with example usage: check_corrupted_videos(reader, wrong_video, msg) without return types