diff --git a/pandora/taskqueue/models.py b/pandora/taskqueue/models.py
index baf18a86..1d114a2c 100644
--- a/pandora/taskqueue/models.py
+++ b/pandora/taskqueue/models.py
@@ -167,7 +167,7 @@ class Task(models.Model):
             job = self.get_job()
             if job:
                 print(job)
-                r = celery.task.control.revoke(job['id'])
+                r = app.control.revoke(job['id'])
                 print(r)
                 for f in self.item.files.filter(encoding=True):
                     f.delete()
diff --git a/pandora/websocket/__init__.py b/pandora/websocket/__init__.py
index e012f868..ef74deed 100644
--- a/pandora/websocket/__init__.py
+++ b/pandora/websocket/__init__.py
@@ -1,11 +1,11 @@
 # -*- coding: utf-8 -*-
 
-from celery.execute import send_task
 from django.conf import settings
+from app.celery import app
 
 
 key = 'websocket'
 
 def trigger_event(event, data):
     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)