Я использую уведомления pubsub для облачного хранилища для чтения новых файлов в потоке данных.Я запускаю потоковый конвейер, который читает из pubsub, затем ptransform, который возвращает путь к файлу, затем я пытаюсь прочитать ReadFromText, чтобы получить входные данные из pcollection путей к файлам.Но он не позволяет мне читать путь из pcollection, похоже, для начала ему нужен путь к файлу.Я получаю ошибку:
TypeError: _TextSource: file_pattern must be of type string or ValueProvider; got None instead