code: def webdataset_raw_pipeline(
      paths,
      index_paths,
      ext,
      case_sensitive_extensions=True,
      missing_component_behavior="empty",
      dtypes=None,
      dont_use_mmap=False,
      num_shards=1,
      shard_id=0,
      skip_cached_images=False,
      pad_last_batch=False,
      lazy_init=False,
      read_ahead=False,
      stick_to_shard=False,
  ):
      out = readers.webdataset(
          paths=paths,
          index_paths=index_paths,
          ext=ext,
          case_sensitive_extensions=case_sensitive_extensions,
          missing_component_behavior=missing_component_behavior,
          dtypes=dtypes,
          dont_use_mmap=dont_use_mmap,
          prefetch_queue_depth=1,
          num_shards=num_shards,
          shard_id=shard_id,
          stick_to_shard=stick_to_shard,
          skip_cached_images=skip_cached_images,
          pad_last_batch=pad_last_batch,
          lazy_init=lazy_init,
          read_ahead=read_ahead,
      )
      return out if not isinstance(out, list) else tuple(out)
  
file_path: DALI/dali/test/python/webdataset_base.py
imports: from nvidia.dali import pipeline_def
  from nvidia.dali.fn import readers
  from nose.tools import assert_equal
  import tempfile
  from subprocess import call
  import os
  import tarfile
label_desc: Use image node_id 1 for calling a global function with example usage: webdataset_raw_pipeline(paths, index_paths, ext, case_sensitive_extensions, missing_component_behavior, dtypes, dont_use_mmap, num_shards, shard_id, skip_cached_images, pad_last_batch, lazy_init, read_ahead, stick_to_shard) and returns: unknown