def __init__(self, source):
    self.source = source
    if source.is_gcs_source:
      # pylint: disable=g-import-not-at-top
      from google.cloud.dataflow.io import gcsio
      self.file_paths = gcsio.GcsIO().glob(self.source.file_path)
    else:
      self.file_paths = glob.glob(self.source.file_path)
    if not self.file_paths:
      raise RuntimeError(
          'No files found for path: %s' % self.source.file_path)
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/io/fileio.py/TextMultiFileReader.__init__/original