From f29f108e4983b35ec24f70b1956d1ad00073feee Mon Sep 17 00:00:00 2001 From: Étienne Loks Date: Fri, 15 Mar 2019 18:57:45 +0100 Subject: Celery: manage cached_label update with tasks --- ishtar_common/models_imports.py | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) (limited to 'ishtar_common/models_imports.py') diff --git a/ishtar_common/models_imports.py b/ishtar_common/models_imports.py index 904f3f013..20c3bf9c4 100644 --- a/ishtar_common/models_imports.py +++ b/ishtar_common/models_imports.py @@ -47,11 +47,7 @@ from ishtar_common.data_importer import Importer, ImportFormater, \ IntegerFormater, FloatFormater, UnicodeFormater, DateFormater, \ TypeFormater, YearFormater, StrToBoolean, FileFormater, InseeFormater, \ ImporterError - -if settings.USE_BACKGROUND_TASK: - from background_task import background -else: - background = lambda x: x +from ishtar_common.utils import task logger = logging.getLogger(__name__) @@ -859,7 +855,7 @@ delayed_check = None if settings.USE_BACKGROUND_TASK: - @background(schedule=1) + @task() def delayed_import(import_pk, session_key): try: imp = Import.objects.get(pk=import_pk) @@ -867,7 +863,7 @@ if settings.USE_BACKGROUND_TASK: pass imp.importation(session_key=session_key) - @background(schedule=1) + @task() def delayed_check(import_pk, session_key): try: imp = Import.objects.get(pk=import_pk) -- cgit v1.2.3