From 1553b634f36f9ef0909f83dcfe1b6d4a1ced9802 Mon Sep 17 00:00:00 2001 From: Jarek Potiuk Date: Thu, 29 May 2025 21:07:12 +0200 Subject: [PATCH] [v3-0-test] Make test_scheduler_job work locally after moving examples (#50917) There was an issue with the test after migrating standard provider examples to ... standard provider (#49978) that made the test work only in Breeze and not in local env. (cherry picked from commit 21f4a400d55785f364afa522b572219ef0ab528f) Co-authored-by: Jarek Potiuk --- airflow-core/tests/unit/jobs/test_scheduler_job.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow-core/tests/unit/jobs/test_scheduler_job.py b/airflow-core/tests/unit/jobs/test_scheduler_job.py index 9caeb067e09ad..ac492590e5b65 100644 --- a/airflow-core/tests/unit/jobs/test_scheduler_job.py +++ b/airflow-core/tests/unit/jobs/test_scheduler_job.py @@ -5721,7 +5721,7 @@ def test_find_and_purge_task_instances_without_heartbeats_nothing(self): @pytest.mark.usefixtures("testing_dag_bundle") def test_find_and_purge_task_instances_without_heartbeats(self, session, create_dagrun): - dagfile = os.path.join(EXAMPLE_STANDARD_DAGS_FOLDER, "example_branch_operator.py") + dagfile = EXAMPLE_STANDARD_DAGS_FOLDER / "example_branch_operator.py" dagbag = DagBag(dagfile) dag = dagbag.get_dag("example_branch_operator") dm = LazyDeserializedDAG(data=SerializedDAG.to_dict(dag)) @@ -5787,7 +5787,7 @@ def test_task_instance_heartbeat_timeout_message(self, session, create_dagrun): """ Check that the task instance heartbeat timeout message comes out as expected """ - dagfile = os.path.join(EXAMPLE_STANDARD_DAGS_FOLDER, "example_branch_operator.py") + dagfile = EXAMPLE_STANDARD_DAGS_FOLDER / "example_branch_operator.py" dagbag = DagBag(dagfile) dag = dagbag.get_dag("example_branch_operator") dm = LazyDeserializedDAG(data=SerializedDAG.to_dict(dag))