code: def test_video_input_input_queue(device, n_test_files):
      """
      Checks the input queue on `fn.inputs.video` operator.
      """
      input_name = "VIDEO_INPUT"
      batch_size = 3
      frames_per_sequence = 4
  
      input_pipe = video_input_pipeline(
          input_name=input_name,
          batch_size=batch_size,
          sequence_length=frames_per_sequence,
          device=device,
          **common_pipeline_params,
      )
  
      input_pipe.build()
      for i in range(n_test_files):
          input_pipe.feed_input(input_name, np.array([[files[i]]]))
  
      n_runs = 0
      for i in range(n_test_files):
          num_frames = get_num_frames(files[i])
          ni, nfs, nfips = get_batch_outline(
              num_frames, frames_per_sequence, batch_size
          )
          n_runs += ni + (1 if nfs + nfips > 0 else 0)
  
      for _ in range(n_runs):
          input_pipe.run()
      # If exception has not been thrown, the test pass.
  
      with assert_raises(
          RuntimeError,
          glob="No data was provided to the InputOperator. Make sure to feed it properly.",
      ):
          input_pipe.run()
  
file_path: DALI/dali/test/python/input/test_video.py
imports: import glob
  import itertools
  import numpy
  import nvidia.dali.fn
  import nvidia.dali.types
  from nose2.tools import params
  from nose_utils import assert_raises
  from nvidia.dali import pipeline_def
  from test_utils import get_dali_extra_path, to_array
label_desc: Use image node_id 9 for calling a global function with example usage: test_video_input_input_queue(device, n_test_files) without return types