mirror of
https://github.com/paperless-ngx/paperless-ngx.git
synced 2025-04-02 13:45:10 -05:00
fix database locked error
This commit is contained in:
parent
3dbb7e5781
commit
c87ca25f22
@ -8,7 +8,6 @@ from documents.models import StoragePath
|
|||||||
from documents.permissions import set_permissions_for_object
|
from documents.permissions import set_permissions_for_object
|
||||||
from documents.tasks import bulk_update_documents
|
from documents.tasks import bulk_update_documents
|
||||||
from documents.tasks import update_document_archive_file
|
from documents.tasks import update_document_archive_file
|
||||||
from documents.tasks import update_owner_for_object
|
|
||||||
|
|
||||||
|
|
||||||
def set_correspondent(doc_ids, correspondent):
|
def set_correspondent(doc_ids, correspondent):
|
||||||
@ -136,7 +135,7 @@ def set_permissions(doc_ids, set_permissions, owner=None):
|
|||||||
|
|
||||||
qs = Document.objects.filter(id__in=doc_ids)
|
qs = Document.objects.filter(id__in=doc_ids)
|
||||||
|
|
||||||
update_owner_for_object.delay(document_ids=doc_ids, owner=owner)
|
qs.update(owner=owner)
|
||||||
|
|
||||||
for doc in qs:
|
for doc in qs:
|
||||||
set_permissions_for_object(set_permissions, doc)
|
set_permissions_for_object(set_permissions, doc)
|
||||||
|
@ -13,7 +13,6 @@ from asgiref.sync import async_to_sync
|
|||||||
from celery import shared_task
|
from celery import shared_task
|
||||||
from channels.layers import get_channel_layer
|
from channels.layers import get_channel_layer
|
||||||
from django.conf import settings
|
from django.conf import settings
|
||||||
from django.contrib.auth.models import User
|
|
||||||
from django.db import transaction
|
from django.db import transaction
|
||||||
from django.db.models.signals import post_save
|
from django.db.models.signals import post_save
|
||||||
from documents import barcodes
|
from documents import barcodes
|
||||||
@ -312,12 +311,3 @@ def update_document_archive_file(document_id):
|
|||||||
)
|
)
|
||||||
finally:
|
finally:
|
||||||
parser.cleanup()
|
parser.cleanup()
|
||||||
|
|
||||||
|
|
||||||
@shared_task
|
|
||||||
def update_owner_for_object(document_ids, owner):
|
|
||||||
documents = Document.objects.filter(id__in=document_ids)
|
|
||||||
ownerUser = User.objects.get(pk=owner) if owner is not None else None
|
|
||||||
for document in documents:
|
|
||||||
document.owner = ownerUser if owner is not None else None
|
|
||||||
document.save()
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user