[beam] branch master updated: [BEAM-8267] remove spurious error on Py worker shutdown

[ib...@apache.org]

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

ibzib 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 ddf8a53  [BEAM-8267] remove spurious error on Py worker shutdown
     new f0aa877  Merge pull request #9600 from ibzib/no-process
ddf8a53 is described below

commit ddf8a5354c43e9914501216ce5c8b4a31f3604fb
Author: Kyle Weaver <kc...@google.com>
AuthorDate: Tue Sep 17 11:30:05 2019 -0700

    [BEAM-8267] remove spurious error on Py worker shutdown
---
 sdks/python/apache_beam/runners/worker/worker_pool_main.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/runners/worker/worker_pool_main.py b/sdks/python/apache_beam/runners/worker/worker_pool_main.py
index fa974c2..94e8ec5 100644
--- a/sdks/python/apache_beam/runners/worker/worker_pool_main.py
+++ b/sdks/python/apache_beam/runners/worker/worker_pool_main.py
@@ -123,7 +123,8 @@ class BeamFnExternalWorkerPoolServicer(
   def StopWorker(self, stop_worker_request, unused_context):
     # applicable for process mode to ensure process cleanup
     # thread based workers terminate automatically
-    worker_process = self._worker_processes.pop(stop_worker_request.worker_id)
+    worker_process = self._worker_processes.pop(stop_worker_request.worker_id,
+                                                None)
     if worker_process:
       def kill_worker_process():
         try: