Skip to content

Commit 2d2d8a2

Browse files
authored
Set task name for 2.11.X path (#63746)
fixes #63729 Celery now uses explicit task names when submitting tasks to workers, make sure to set that explicit name on the older module level app that Airflow 2.x uses.
1 parent b9faa65 commit 2d2d8a2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ def execute_workload(input: str) -> None:
228228

229229
if not AIRFLOW_V_3_0_PLUS:
230230

231-
@app.task
231+
@app.task(name="execute_command")
232232
def execute_command(command_to_exec: CommandType) -> None:
233233
"""Execute command."""
234234
EXECUTE_TASKS_NEW_PYTHON_INTERPRETER = not hasattr(os, "fork") or conf.getboolean(

0 commit comments

Comments
 (0)