From 4a7f84c0198013b01010d9e9847dc697d1f95aed Mon Sep 17 00:00:00 2001 From: Renzo Meister Date: Thu, 21 Jul 2016 16:42:34 +0200 Subject: [PATCH] The write of state will fail because of connector himself also writes this state. So it is not neccessary to write the state here. --- connector_flow/task/abstract_task.py | 2 -- 1 file changed, 2 deletions(-) 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):