From d8b346b991b677dbd4dd28fac1e794aeda8d99ab Mon Sep 17 00:00:00 2001 From: j Date: Mon, 21 Aug 2023 23:25:03 +0200 Subject: [PATCH] update tasks to new api --- tasks.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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()