diff --git a/tasks.py b/tasks.py
index a1984d7..2103ea5 100644
--- a/tasks.py
+++ b/tasks.py
@@ -1,11 +1,12 @@
 import os
 import subprocess
 
-from celery.task import task
+from app.celery import app
 
 base = os.path.dirname(__file__)
 
-@task(queue="encoding")
+
+@app.task(queue="encoding")
 def import_documents(urls):
     for url in urls:
         url = url.strip()