Для проверки структуры сообщения перед публикацией в Pub / Sub и после использования из Pub / Sub я использую сообщения Protobuf.Тот же protobuf скомпилированный вывод metrics_pb2.py находится внутри приложения Python издателя и приложения Beam подписчика.Мой конвейер Beam работает на моей местности без каких-либо проблем.Но когда я пытаюсь запустить его на Google Dataflow , я получаю эту ошибку
PicklingError: Can't pickle <class 'metrics_pb2.MetricGlucose'>: import of module metrics_pb2 failed
Даже у меня есть многомодульный конвейер данных, и я использую setup.py *Файл 1011 *, и все остальные модули можно найти по конвейеру, я не знаю, почему конвейер не может увидеть эти выходные файлы, скомпилированные с помощью protobuf. * 1012 * Есть идеи?