fixup! Fix lint

mransley · May 1, 2020 · b740404 · b740404
1 parent a0d215c
commit b740404
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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: