paradizelost/paperless-ngx
1
0
Fork 0
mirror of https://github.com/paperless-ngx/paperless-ngx.git synced 2025-07-12 17:04:40 -05:00
Code Issues Packages Projects Releases Wiki Activity

Update consumer.py

Browse Source
This commit is contained in:
shamoon 2025-06-26 14:49:08 -07:00
parent ba91bb154a
commit 056b314a89
No known key found for this signature in database
1 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/documents/consumer.py
View File

@ -468,7 +468,6 @@ class ConsumerPlugin(
# now that everything is done, we can start to store the document # now that everything is done, we can start to store the document
# in the system. This will be a transaction and reasonably fast. # in the system. This will be a transaction and reasonably fast.
success = False success = False
result = None
store_exception = None store_exception = None
try: try:
with transaction.atomic(): with transaction.atomic():
@ -572,24 +571,25 @@ class ConsumerPlugin(
# Return the most up to date fields # Return the most up to date fields
document.refresh_from_db() document.refresh_from_db()
result = f"Success. New document id {document.pk} created" document_parser.cleanup()
elif store_exception: tempdir.cleanup()
self._fail( return f"Success. New document id {document.pk} created"
str(store_exception),
f"The following error occurred while storing document "
f"{self.filename} after parsing: {store_exception}",
exc_info=True,
exception=store_exception,
)
else: else:
self._fail( document_parser.cleanup()
ConsumerStatusShortMessage.FAILED, tempdir.cleanup()
f"Error occurred while saving {self.filename}.", if store_exception:
) self._fail(
str(store_exception),
document_parser.cleanup() f"The following error occurred while storing document "
tempdir.cleanup() f"{self.filename} after parsing: {store_exception}",
return result exc_info=True,
exception=store_exception,
)
else:
self._fail(
ConsumerStatusShortMessage.FAILED,
f"Error occurred while saving {self.filename}.",
)
def _parse_title_placeholders(self, title: str) -> str: def _parse_title_placeholders(self, title: str) -> str:
local_added = timezone.localtime(timezone.now()) local_added = timezone.localtime(timezone.now())