jscheffl commented on code in PR #45038:
URL: https://github.com/apache/airflow/pull/45038#discussion_r1895048410
##########
providers/tests/celery/executors/test_celery_executor.py:
##########
@@ -399,3 +399,12 @@ def test_celery_task_acks_late_loaded_from_string():
# reload celery conf to apply the new config
importlib.reload(default_celery)
assert default_celery.DEFAULT_CELERY_CONFIG["task_acks_late"] is False
+
+
+@conf_vars({("celery", "extra_celery_config"): '{"worker_max_tasks_per_child":
10}'})
+def test_celery_extra_celery_config_loaded_from_string():
+ import importlib
+
+ # reload celery conf to apply the new config
+ importlib.reload(default_celery)
+ assert default_celery.DEFAULT_CELERY_CONFIG["extra_celery_config"] ==
{"worker_max_tasks_per_child": 10}
Review Comment:
As you did not hit it (yet) as CI was broken, in the test baloon PR
https://github.com/apache/airflow/pull/45160 the check fail.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
