From 5399ace3facaa0cd863b9c7682240ff5fd4ad5cc Mon Sep 17 00:00:00 2001 From: Jens Scheffler Date: Sat, 21 Dec 2024 15:01:06 +0100 Subject: [PATCH] Prevent task sdk tests with LocalExecutor fail with retries --- tests/cli/commands/remote_commands/test_task_command.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/tests/cli/commands/remote_commands/test_task_command.py b/tests/cli/commands/remote_commands/test_task_command.py index 66177c2d84ecd..843d6817cdcc5 100644 --- a/tests/cli/commands/remote_commands/test_task_command.py +++ b/tests/cli/commands/remote_commands/test_task_command.py @@ -496,6 +496,8 @@ def test_cli_run_no_local_no_raw_runs_executor(self, dag_maker): mock.patch( "airflow.executors.executor_loader.ExecutorLoader.get_default_executor" ) as get_default_mock, + mock.patch("airflow.executors.local_executor.SimpleQueue"), # Prevent a task being queued + mock.patch("airflow.executors.local_executor.LocalExecutor.end"), ): EmptyOperator(task_id="task1") EmptyOperator(task_id="task2", executor="foo_executor_alias")