From 0ba9fabbd34903b745115babf28d0ccab9a4deb3 Mon Sep 17 00:00:00 2001 From: Ash Berlin-Taylor Date: Fri, 4 Apr 2025 19:24:55 +0100 Subject: [PATCH] Fix Celery Executor on Airflow 2.x again. Prior to 984c61d28 this code looked like: ```python result = task_to_run.apply_async(args=[command], queue=queue) ``` Closes #47781 --- .../airflow/providers/celery/executors/celery_executor_utils.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py b/providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py index cbe3eec2309b4..555c4147dd053 100644 --- a/providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py +++ b/providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py @@ -265,6 +265,8 @@ def send_task_to_executor( if TYPE_CHECKING: assert isinstance(args, workloads.BaseWorkload) args = (args.model_dump_json(),) + else: + args = [args] # type: ignore[list-item] try: with timeout(seconds=OPERATION_TIMEOUT): result = task_to_run.apply_async(args=args, queue=queue)