[beam] branch master updated: [BEAM-4374] Fix missing deletion of metrics.

[lc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 80ebb70  [BEAM-4374] Fix missing deletion of metrics.
     new 95a5944  Merge pull request #11363 from lukecwik/beam4374
80ebb70 is described below

commit 80ebb703a528a67afeda9cca857d251769057dd1
Author: Luke Cwik <lc...@google.com>
AuthorDate: Thu Apr 9 09:40:25 2020 -0700

    [BEAM-4374] Fix missing deletion of metrics.
---
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker.py b/sdks/python/apache_beam/runners/worker/sdk_worker.py
index 7324263..eed471d 100644
--- a/sdks/python/apache_beam/runners/worker/sdk_worker.py
+++ b/sdks/python/apache_beam/runners/worker/sdk_worker.py
@@ -580,7 +580,6 @@ class SdkWorker(object):
     return beam_fn_api_pb2.InstructionResponse(
         instruction_id=instruction_id,
         process_bundle_progress=beam_fn_api_pb2.ProcessBundleProgressResponse(
-            metrics=processor.metrics() if processor else None,
             monitoring_infos=monitoring_infos,
             monitoring_data={
                 SHORT_ID_CACHE.getShortId(info): info.payload