Added unit test for the additional config and addressed comments

apache · Dec 18, 2024 · b719528 · b719528
1 parent 84f1e81
commit b719528
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/providers/src/airflow/providers/celery/executors/default_celery.py b/providers/src/airflow/providers/celery/executors/default_celery.py
@@ -87,7 +87,7 @@ def _broker_supports_visibility_timeout(url):
     ),
     "worker_concurrency": conf.getint("celery", "WORKER_CONCURRENCY", fallback=16),
     "worker_enable_remote_control": conf.getboolean("celery", "worker_enable_remote_control", fallback=True),
-    **extra_celery_config
+    **extra_celery_config,
 }