From ea1d033f6cd0fbe19082ace146081fa28f83a051 Mon Sep 17 00:00:00 2001 From: Victor Skvortsov Date: Wed, 25 Mar 2026 15:37:40 +0500 Subject: [PATCH] Drop redundant instance select with lock --- .../server/background/pipeline_tasks/jobs_submitted.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/dstack/_internal/server/background/pipeline_tasks/jobs_submitted.py b/src/dstack/_internal/server/background/pipeline_tasks/jobs_submitted.py index 0d79d4bae..81c407a05 100644 --- a/src/dstack/_internal/server/background/pipeline_tasks/jobs_submitted.py +++ b/src/dstack/_internal/server/background/pipeline_tasks/jobs_submitted.py @@ -832,9 +832,10 @@ async def _lock_assignment_fleet_for_existing_instance_assignment( if not instance_ids: return None - if is_db_sqlite(): - await sqlite_commit(session) + if not is_db_sqlite(): + return fleets_with_instances[0] + await sqlite_commit(session) await exit_stack.enter_async_context( get_locker(get_db().dialect_name).lock_ctx(InstanceModel.__tablename__, instance_ids) )