summaryrefslogtreecommitdiff
path: root/ishtar_common/models_imports.py
diff options
context:
space:
mode:
authorÉtienne Loks <etienne.loks@iggdrasil.net>2019-03-15 18:57:45 +0100
committerÉtienne Loks <etienne.loks@iggdrasil.net>2019-06-17 13:21:27 +0200
commitf29f108e4983b35ec24f70b1956d1ad00073feee (patch)
treeeb79f424c92c37189346e956f9fe5b8f89ba4f22 /ishtar_common/models_imports.py
parentfd0cad6737e1b10ca8574428e1884e8c4755146e (diff)
downloadIshtar-f29f108e4983b35ec24f70b1956d1ad00073feee.tar.bz2
Ishtar-f29f108e4983b35ec24f70b1956d1ad00073feee.zip
Celery: manage cached_label update with tasks
Diffstat (limited to 'ishtar_common/models_imports.py')
-rw-r--r--ishtar_common/models_imports.py10
1 files changed, 3 insertions, 7 deletions
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)