kalluripradeep commented on code in PR #63110:
URL: https://github.com/apache/airflow/pull/63110#discussion_r2902455354
##########
providers/celery/tests/unit/celery/executors/test_celery_executor.py:
##########
@@ -687,3 +687,25 @@ def test_task_routing_through_team_specific_app(self,
mock_send_tasks, monkeypat
# Critical: task belongs to team A's app, not module-level app
assert task_from_call.app is team_a_executor.celery_app
assert task_from_call.name == "execute_command"
+
+
+def test_celery_tasks_registered_on_import():
Review Comment:
Yes exactly — `execute_command` is Airflow 2.x only. I've added a `# TODO:
remove this block when min supported Airflow version is >= 3.0` comment on that
assertion to make the cleanup intent explicit. Thanks for flagging!
--
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]
