We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 744478b commit 23dcafaCopy full SHA for 23dcafa
1 file changed
sdks/python/apache_beam/runners/worker/worker_pool_main.py
@@ -190,6 +190,8 @@ def StopWorker(
190
_LOGGER.info("Stopping worker %s" % stop_worker_request.worker_id)
191
kill_process_gracefully(worker_process)
192
193
+ # applicable for thread mode to ensure thread cleanup by
194
+ # unblocking the harness request stream.
195
worker_thread_harness = self._worker_threads.pop(
196
stop_worker_request.worker_id, None)
197
if worker_thread_harness:
0 commit comments