Added unit test for the additional config and addressed comments

sachin-arora-cashfree · arorasachin9 · commit b719528a77ab · 2024-12-19T00:19:48.000+05:30
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,
 }
 
 

Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ def _broker_supports_visibility_timeout(url):`
`87`	`87`	`),`
`88`	`88`	`"worker_concurrency": conf.getint("celery", "WORKER_CONCURRENCY", fallback=16),`
`89`	`89`	`"worker_enable_remote_control": conf.getboolean("celery", "worker_enable_remote_control", fallback=True),`
`90`		`- **extra_celery_config`
	`90`	`+ **extra_celery_config,`
`91`	`91`	`}`
`92`	`92`
`93`	`93`