diff --git a/tests/triggers/test_external_task.py b/tests/triggers/test_external_task.py index 7bb41c34502d6..d0343807dfcc9 100644 --- a/tests/triggers/test_external_task.py +++ b/tests/triggers/test_external_task.py @@ -42,6 +42,7 @@ class TestWorkflowTrigger: RUN_ID = "external_task_run_id" STATES = ["success", "fail"] + @pytest.mark.flaky(reruns=5) @mock.patch("airflow.triggers.external_task._get_count") @pytest.mark.asyncio async def test_task_workflow_trigger_success(self, mock_get_count):