diff --git a/connector_flow/task/abstract_task.py b/connector_flow/task/abstract_task.py
index 0fae0cf10..765dbdf53 100644
--- a/connector_flow/task/abstract_task.py
+++ b/connector_flow/task/abstract_task.py
@@ -94,6 +94,7 @@ def run(self, chunk_id=None, **kwargs):
             result = self.read_chunk(**kwargs)
             new_state = 'done'
         except:
+            self.session.env.cr.rollback()
             raise
         finally:
             chunk.write({'state': new_state})