Remove extra selectin

r4victor · r4victor · commit eec2d26642c0 · 2025-07-24T16:13:14.000+05:00
diff --git a/src/dstack/_internal/server/background/tasks/process_runs.py b/src/dstack/_internal/server/background/tasks/process_runs.py
@@ -95,9 +95,10 @@ async def _process_next_run():
                         ),
                     ),
                 )
+                .options(joinedload(RunModel.jobs).load_only(JobModel.id))
                 .order_by(RunModel.last_processed_at.asc())
                 .limit(1)
-                .with_for_update(skip_locked=True, key_share=True)
+                .with_for_update(skip_locked=True, key_share=True, of=RunModel)
             )
             run_model = res.scalar()
             if run_model is None:

Original file line number	Diff line number	Diff line change
`@@ -95,9 +95,10 @@ async def _process_next_run():`
`95`	`95`	`),`
`96`	`96`	`),`
`97`	`97`	`)`
	`98`	`+ .options(joinedload(RunModel.jobs).load_only(JobModel.id))`
`98`	`99`	`.order_by(RunModel.last_processed_at.asc())`
`99`	`100`	`.limit(1)`
`100`		`- .with_for_update(skip_locked=True, key_share=True)`
	`101`	`+ .with_for_update(skip_locked=True, key_share=True, of=RunModel)`
`101`	`102`	`)`
`102`	`103`	`run_model = res.scalar()`
`103`	`104`	`if run_model is None:`