From b740404ec4f9c06940cfcd06388f3fb920364a62 Mon Sep 17 00:00:00 2001 From: Luke Cwik Date: Fri, 1 May 2020 14:14:57 -0700 Subject: [PATCH] fixup! Fix lint --- sdks/python/apache_beam/utils/thread_pool_executor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/utils/thread_pool_executor.py b/sdks/python/apache_beam/utils/thread_pool_executor.py index 2b5c494666725..a5443ed5c4b2b 100644 --- a/sdks/python/apache_beam/utils/thread_pool_executor.py +++ b/sdks/python/apache_beam/utils/thread_pool_executor.py @@ -109,7 +109,7 @@ def submit(self, fn, *args, **kwargs): self._idle_worker_queue.get(block=False).assign_work(work_item) # If we have more idle threads then the max allowed, shutdown a thread. - if (self._idle_worker_queue.qsize() > self._max_idle_threads): + if self._idle_worker_queue.qsize() > self._max_idle_threads: try: self._idle_worker_queue.get(block=False).shutdown() except queue.Empty: