

def __init__(self, source):
    self.source = source
    if source.is_gcs_source:
        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