Comment on non-repeatable read

r4victor · r4victor · commit bd8eb553cf4a · 2026-01-16T11:29:33.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
@@ -147,7 +147,7 @@ async def _process_next_run():
             )
             job_models = res.scalars().all()
             if len(run_model.jobs) != len(job_models):
-                # Some jobs are locked
+                # Some jobs are locked or there was a non-repeatable read
                 return
             job_ids = [j.id for j in run_model.jobs]
             run_lockset.add(run_model.id)

Original file line number	Diff line number	Diff line change
`@@ -147,7 +147,7 @@ async def _process_next_run():`
`147`	`147`	`)`
`148`	`148`	`job_models = res.scalars().all()`
`149`	`149`	`if len(run_model.jobs) != len(job_models):`
`150`		`- # Some jobs are locked`
	`150`	`+ # Some jobs are locked or there was a non-repeatable read`
`151`	`151`	`return`
`152`	`152`	`job_ids = [j.id for j in run_model.jobs]`
`153`	`153`	`run_lockset.add(run_model.id)`