Update DataImporterTask to save valid lines

valdergallo · Feb 12, 2015 · 95b18e5 · 95b18e5
1 parent fc0ceb9
commit 95b18e5
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/data_importer/__init__.py b/data_importer/__init__.py
@@ -3,5 +3,5 @@
 
 
 __doc__ = 'Data Importer'
-__version__ = '2.2.0'
+__version__ = '2.2.1'
 __author__ = 'Valder Gallo <valdergallo@gmail.com>'
diff --git a/data_importer/tasks.py b/data_importer/tasks.py
@@ -57,8 +57,19 @@ def run(self, importer=None, source="", owner=None, message="",
         lock_id = "%s-lock" % (self.name)
 
         if acquire_lock(lock_id):
-            if self.parser.is_valid():
+            """
+            If parser use raise_errors the error message will raise
+            and logged by celery
+            """
+
+            if not self.parser.raise_errors:
+                # validate content
+                self.parser.is_valid()
+                # save valid values
                 self.parser.save()
+            else:
+                if self.parser.is_valid():
+                    self.parser.save()
 
             message += "\n"