lgcosta/paperless-ngx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use existing celery app

Browse Source
This commit is contained in:
shamoon 2024-02-12 11:19:54 -08:00
parent 4a5bfee4ae
commit 603f1397a8
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/documents/views.py
View File

@ -14,7 +14,6 @@ from unicodedata import normalize
from urllib.parse import quote from urllib.parse import quote
import pathvalidate import pathvalidate
from celery import Celery
from django.conf import settings from django.conf import settings
from django.contrib.auth.models import User from django.contrib.auth.models import User
from django.db import connections from django.db import connections
@ -144,6 +143,7 @@ from documents.serialisers import WorkflowTriggerSerializer
from documents.signals import document_updated from documents.signals import document_updated
from documents.tasks import consume_file from documents.tasks import consume_file
from paperless import version from paperless import version
from paperless.celery import app as celery_app
from paperless.config import GeneralConfig from paperless.config import GeneralConfig
from paperless.db import GnuPG from paperless.db import GnuPG
from paperless.views import StandardPagination from paperless.views import StandardPagination
@ -1591,9 +1591,7 @@ class SystemStatusView(GenericAPIView, PassUserMixin):
redis_error = str(e) redis_error = str(e)
try: try:
app = Celery("paperless") ping = celery_app.control.inspect().ping()
app.config_from_object("django.conf:settings", namespace="CELERY")
ping = app.control.inspect().ping()
first_worker_ping = ping[next(iter(ping.keys()))] first_worker_ping = ping[next(iter(ping.keys()))]
if first_worker_ping["ok"] == "pong": if first_worker_ping["ok"] == "pong":
celery_active = "OK" celery_active = "OK"