Я запускаю потоковый конвейер в Apache Beam Python SDK.Когда я запускаю его из обработчика потока данных и проверяю шаги задания потока данных, на нем не отображаются такие метрики, как добавленные элементы и предполагаемый размер.
