diff --git a/connector_flow/task/abstract_task.py b/connector_flow/task/abstract_task.py
index 0fae0cf10..63015c757 100644
--- a/connector_flow/task/abstract_task.py
+++ b/connector_flow/task/abstract_task.py
@@ -17,12 +17,12 @@
 #    along with this program.  If not, see <http://www.gnu.org/licenses/>.
 #
 ##############################################################################
-
-from openerp.addons.connector.session import ConnectorSession
-from openerp import _
 import simplejson
 from base64 import b64encode, b64decode
 
+from openerp import _
+from openerp.addons.connector.session import ConnectorSession
+
 
 class AbstractTask(object):
 
@@ -96,7 +96,10 @@ def run(self, chunk_id=None, **kwargs):
         except:
             raise
         finally:
-            chunk.write({'state': new_state})
+            try:
+                chunk.write({'state': new_state})
+            except:
+                pass
         return result
 
     def read_chunk(self, **kwargs):