basic async case processing

dimagi · Feb 13, 2014 · 108056d · 108056d
1 parent ef1facb
commit 108056d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/casexml/apps/case/signals.py b/casexml/apps/case/signals.py
@@ -18,8 +18,8 @@ def process_cases(sender, xform, config=None, **kwargs):
 
 @log_exception()
 def _process_cases(sender, xform, config=None, **kwargs):
-    from casexml.apps.case import process_cases
-    process_cases(xform, config)
+    from casexml.apps.case.tasks import process_cases
+    process_cases.delay(xform, config)
 
 
 successful_form_received.connect(_process_cases)

diff --git a/casexml/apps/case/tasks.py b/casexml/apps/case/tasks.py
@@ -0,0 +1,7 @@
+from celery.task import task
+
+
+@task
+def process_cases(xform, config=None):
+    from casexml.apps.case import process_cases
+    process_cases(xform, config)