diff --git a/connector_flow/task/abstract_task.py b/connector_flow/task/abstract_task.py
index 0fae0cf10..37a2e74ae 100644
--- a/connector_flow/task/abstract_task.py
+++ b/connector_flow/task/abstract_task.py
@@ -95,8 +95,6 @@ def run(self, chunk_id=None, **kwargs):
             new_state = 'done'
         except:
             raise
-        finally:
-            chunk.write({'state': new_state})
         return result
 
     def read_chunk(self, **kwargs):