code: def find_all_pipeline_csvs(
          csv_glob_path="/opt/antinex/datasets/**/*.csv"):
      
  
      log.info("finding pipeline csvs in dir={}".format(csv_glob_path))
  
      pipeline_files = []
  
      for csv_file in glob.iglob(csv_glob_path,
                                 recursive=True):
          log.info(("adding file={}")
                   .format(csv_file))
          pipeline_files.append(csv_file)
      # end of for all csvs
  
      log.info(("pipeline files={}")
               .format(len(pipeline_files)))
  
      return pipeline_files
docs: find_all_pipeline_csvs
  
      :param csv_glob_path: path to csvs