Luke Cwik created BEAM-9475: ------------------------------- Summary: New style metrics in portability throw error Key: BEAM-9475 URL: https://issues.apache.org/jira/browse/BEAM-9475 Project: Beam Issue Type: Bug Components: sdk-py-harness Reporter: Luke Cwik Assignee: Luke Cwik Fix For: 2.20.0
for mi in op.monitoring_infos(transform_id).values(): File "apache_beam/runners/worker/operations.py", line 815, in apache_beam.runners.worker.operations.SdfProcessSizedElements.monitoring_infos def monitoring_infos(self, transform_id): File "apache_beam/runners/worker/operations.py", line 817, in apache_beam.runners.worker.operations.SdfProcessSizedElements.monitoring_infos with self.lock: File "apache_beam/runners/worker/operations.py", line 822, in apache_beam.runners.worker.operations.SdfProcessSizedElements.monitoring_infos if current_element_progress.completed_work(): TypeError: 'NoneType' object is not callable -- This message was sent by Atlassian Jira (v8.3.4#803005)