New style metrics in portability throw error

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