Skip to content

Commit 63629be

Browse files
committed
Fix reuse instances lock
1 parent 3ff4932 commit 63629be

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/dstack/_internal/server/background/tasks/process_submitted_jobs.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,11 @@ async def _process_submitted_job(session: AsyncSession, job_model: JobModel):
204204
async with get_locker().lock_ctx(InstanceModel.__tablename__, instances_ids):
205205
# Refetch after lock
206206
res = await session.execute(
207-
select(InstanceModel).where(InstanceModel.id.in_(instances_ids))
207+
select(InstanceModel).where(
208+
InstanceModel.id.in_(instances_ids),
209+
InstanceModel.deleted == False,
210+
InstanceModel.job_id.is_(None),
211+
)
208212
)
209213
pool_instances = list(res.scalars().all())
210214
instance = await _assign_job_to_pool_instance(

0 commit comments

Comments
 (0)