You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2020/11/05 22:25:49 UTC
[airflow] branch master updated: Remove redundant parenthesis
(#12118)
This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push:
new 60cf315 Remove redundant parenthesis (#12118)
60cf315 is described below
commit 60cf315d1b61e823ebc73714800bc9e1e3833c12
Author: Kaxil Naik <ka...@gmail.com>
AuthorDate: Thu Nov 5 22:22:11 2020 +0000
Remove redundant parenthesis (#12118)
---
airflow/executors/celery_executor.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py
index 44acab1..e798608 100644
--- a/airflow/executors/celery_executor.py
+++ b/airflow/executors/celery_executor.py
@@ -244,7 +244,7 @@ class CeleryExecutor(BaseExecutor):
task_tuples_to_send: List[TaskInstanceInCelery] = []
- for _ in range(min((open_slots, len(self.queued_tasks)))):
+ for _ in range(min(open_slots, len(self.queued_tasks))):
key, (command, _, queue, simple_ti) = sorted_queue.pop(0)
task_tuples_to_send.append((key, simple_ti, command, queue, execute_command))