0x2620/pandora
2
1
Fork 1
Code Issues 1.3k Pull requests Releases Wiki Activity

celery fixes

Browse source
This commit is contained in:
j 2024-04-05 21:19:57 +01:00
parent 853efbba9a
commit c55c733bcd
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pandora/taskqueue/models.py
View file

@ -167,7 +167,7 @@ class Task(models.Model):
job = self.get_job() job = self.get_job()
if job: if job:
print(job) print(job)
r = celery.task.control.revoke(job['id']) r = app.control.revoke(job['id'])
print(r) print(r)
for f in self.item.files.filter(encoding=True): for f in self.item.files.filter(encoding=True):
f.delete() f.delete()

4
pandora/websocket/__init__.py
View file

@ -1,11 +1,11 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
from celery.execute import send_task
from django.conf import settings from django.conf import settings
from app.celery import app
key = 'websocket' key = 'websocket'
def trigger_event(event, data): def trigger_event(event, data):
if settings.WEBSOCKET: if settings.WEBSOCKET:
send_task('trigger_event', [event, data], exchange=key, routing_key=key) app.send_task('trigger_event', [event, data], exchange=key, routing_key=key)