fixup! Use session.scalar() with limit

apache · May 30, 2023 · c64be9f · c64be9f
1 parent a926956
commit c64be9f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/jobs/job.py b/airflow/jobs/job.py
@@ -252,7 +252,7 @@ def most_recent_job(job_type: str, session: Session = NEW_SESSION) -> Job | None
     :param job_type: job type to query for to get the most recent job for
     :param session: Database session
     """
-    return session.scalars(
+    return session.scalar(
         select(Job)
         .where(Job.job_type == job_type)
         .order_by(
@@ -261,7 +261,7 @@ def most_recent_job(job_type: str, session: Session = NEW_SESSION) -> Job | None
             Job.latest_heartbeat.desc(),
         )
         .limit(1)
-    ).first()
+    )
 
 
 @provide_session