fix test_handle_stuck_queued_tasks_multiple_attempts (apache#44093)

LefterisXefteris · Jan 5, 2025 · 96791ac · 96791ac
1 parent 8c3c201
commit 96791ac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/jobs/test_scheduler_job.py b/tests/jobs/test_scheduler_job.py
@@ -2284,7 +2284,7 @@ def _queue_tasks(tis):
         assert [x.queued_dttm for x in tis] == [None, None]
 
         _queue_tasks(tis=tis)
-        log_events = [x.event for x in session.scalars(select(Log)).all()]
+        log_events = [x.event for x in session.scalars(select(Log).where(Log.run_id == run_id)).all()]
         assert log_events == [
             "stuck in queued reschedule",
             "stuck in queued reschedule",