We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 13b4525 commit ea1d033Copy full SHA for ea1d033
src/dstack/_internal/server/background/pipeline_tasks/jobs_submitted.py
@@ -832,9 +832,10 @@ async def _lock_assignment_fleet_for_existing_instance_assignment(
832
if not instance_ids:
833
return None
834
835
- if is_db_sqlite():
836
- await sqlite_commit(session)
+ if not is_db_sqlite():
+ return fleets_with_instances[0]
837
838
+ await sqlite_commit(session)
839
await exit_stack.enter_async_context(
840
get_locker(get_db().dialect_name).lock_ctx(InstanceModel.__tablename__, instance_ids)
841
)
0 commit comments