We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 62738c1 commit d1e5f63Copy full SHA for d1e5f63
jbi/queue.py
@@ -184,8 +184,12 @@ async def put(self, item: QueueItem):
184
async def remove(self, bug_id: int, identifier: str):
185
bug_dir = self.location / f"{bug_id}"
186
item_path = bug_dir / (identifier + ".json")
187
- item_path.unlink(missing_ok=True)
188
- logger.debug("Removed %s from queue for bug %s", identifier, bug_id)
+ try:
+ logger.debug("Removing %s from queue for bug %s", identifier, bug_id)
189
+ item_path.unlink()
190
+ except FileNotFoundError as exc:
191
+ logger.warning("Could not delete missing item at path %s", str(item_path), exc)
192
+
193
if not any(bug_dir.iterdir()):
194
bug_dir.rmdir()
195
logger.debug("Removed directory for bug %s", bug_id)
0 commit comments