diff --git a/apps/application/flow/workflow_manage.py b/apps/application/flow/workflow_manage.py
index d5342c9c4cf..d2e99bce85d 100644
--- a/apps/application/flow/workflow_manage.py
+++ b/apps/application/flow/workflow_manage.py
@@ -304,11 +304,11 @@ def await_result(self, result):
                 if chunk is None:
                     break
                 yield chunk
-            yield self.get_chunk_content('', True)
         finally:
             self.work_flow_post_handler.handler(self.params['chat_id'], self.params['chat_record_id'],
                                                 self.answer,
                                                 self)
+        yield self.get_chunk_content('', True)
 
     def run_chain_async(self, current_node):
         future = executor.submit(self.run_chain, current_node)