diff --git a/apps/application/flow/workflow_manage.py b/apps/application/flow/workflow_manage.py
index cba2614eb0b..1bf5a0a31ca 100644
--- a/apps/application/flow/workflow_manage.py
+++ b/apps/application/flow/workflow_manage.py
@@ -556,6 +556,7 @@ def run_node_async(self, node):
     def run_node_future(self, node):
         try:
             node.valid_args(node.node_params, node.workflow_params)
+            self.send_progress(node)
             result = self.run_node(node)
             return NodeResultFuture(result, None, 200)
         except Exception as e: