[EWT-569] Airflow Upgrade to 1.10.14 [CP] from 1.10.4+twtr : d8c473e

[CP][EWT-548][AIRFLOW-6527] Make send_task_to_executor timeout configurable (twitter-forks#63) CP of f757a54 Commit already available in 1.10.12
ayushSethi22 · Dec 21, 2020 · 2fb2c2a · 2fb2c2a
1 parent 840dc0c
commit 2fb2c2a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/airflow/config_templates/default_airflow.cfg b/airflow/config_templates/default_airflow.cfg
@@ -595,7 +595,7 @@ pool = prefork
 
 # The number of seconds to wait before timing out ``send_task_to_executor`` or
 # ``fetch_celery_task_state`` operations.
-operation_timeout = 2
+operation_timeout = 10
 
 [celery_broker_transport_options]
 

diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py
@@ -49,7 +49,6 @@
 
 OPERATION_TIMEOUT = conf.getint('celery', 'operation_timeout', fallback=2)
 
-
 '''
 To start the celery worker, run the command:
 airflow worker