Skip to content

Commit 9353531

Browse files
fix: add missing dialect_name parameter to get_locker call
1 parent 69789ac commit 9353531

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77

88
from dstack._internal.core.models.profiles import parse_duration
99
from dstack._internal.core.models.volumes import VolumeStatus
10-
from dstack._internal.server.db import get_session_ctx
10+
from dstack._internal.server.db import get_db, get_session_ctx
1111
from dstack._internal.server.models import VolumeModel
1212
from dstack._internal.server.services.locking import get_locker
1313
from dstack._internal.server.services.volumes import get_volume_configuration
@@ -18,7 +18,7 @@
1818

1919

2020
async def process_idle_volumes():
21-
lock, lockset = get_locker().get_lockset(VolumeModel.__tablename__)
21+
lock, lockset = get_locker(get_db().dialect_name).get_lockset(VolumeModel.__tablename__)
2222
async with get_session_ctx() as session:
2323
# Take lock, select IDs, add to lockset, release lock
2424
async with lock:

0 commit comments

Comments
 (0)