fix (queue): Add explicit rollback on integrity error (#174)

This commit is contained in:
Vineeth Voruganti 2025-07-31 16:50:19 -04:00 committed by GitHub
parent 6338337c2d
commit 0664410878
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions

View File

@ -266,7 +266,8 @@ class QueueManager:
)
self.add_task(task)
except IntegrityError:
# Note: rollback is handled by tracked_db dependency
# Rollback the failed transaction to clear the error state
await db.rollback()
logger.debug(
f"Failed to claim work unit {work_unit}, already owned"
)