Skip to content

Commit c234c25

Browse files
fix: address code review comments
1 parent 9353531 commit c234c25

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
async def process_idle_volumes():
2121
lock, lockset = get_locker(get_db().dialect_name).get_lockset(VolumeModel.__tablename__)
2222
async with get_session_ctx() as session:
23-
# Take lock, select IDs, add to lockset, release lock
2423
async with lock:
2524
res = await session.execute(
2625
select(VolumeModel.id)
@@ -59,8 +58,7 @@ async def process_idle_volumes():
5958
await _delete_idle_volumes(session, to_delete)
6059

6160
finally:
62-
for volume_id in volume_ids:
63-
lockset.discard(volume_id)
61+
lockset.difference_update(volume_ids)
6462

6563

6664
def _should_delete_volume(volume: VolumeModel) -> bool:
@@ -101,7 +99,7 @@ def _get_idle_time(volume: VolumeModel) -> datetime.timedelta:
10199

102100

103101
async def _delete_idle_volumes(session: AsyncSession, volumes: List[VolumeModel]):
104-
"""Delete idle volumes without using the delete_volumes function to avoid locking conflicts."""
102+
"""Mark idle volumes as deleted."""
105103
for volume in volumes:
106104
try:
107105
# Mark volume as deleted

0 commit comments

Comments
 (0)