cubicweb/server/sources/datafeed.py
changeset 11151 4259c55df3e7
parent 11138 78c8e64f3cef
child 11251 b66a8c3eebeb
--- a/cubicweb/server/sources/datafeed.py	Tue Dec 22 09:23:00 2015 +0100
+++ b/cubicweb/server/sources/datafeed.py	Tue Feb 23 12:18:47 2016 +0100
@@ -521,23 +521,9 @@
                 raise
             self.import_log.record_error(str(ex))
             return True
-        error = False
-        commit = self._cw.commit
-        rollback = self._cw.rollback
         for args in parsed:
-            try:
-                self.process_item(*args, raise_on_error=raise_on_error)
-                # commit+set_cnxset instead of commit(free_cnxset=False) to let
-                # other a chance to get our connections set
-                commit()
-            except ValidationError as exc:
-                if raise_on_error:
-                    raise
-                self.source.error('Skipping %s because of validation error %s'
-                                  % (args, exc))
-                rollback()
-                error = True
-        return error
+            self.process_item(*args, raise_on_error=raise_on_error)
+        return False
 
     def parse(self, url):
         stream = self.retrieve_url(url)