diff --git a/apps/application/workflow/nodes/loop_node/loop_node.py b/apps/application/workflow/nodes/loop_node/loop_node.py
index 03c65d4bc3d..c33e4449bcf 100644
--- a/apps/application/workflow/nodes/loop_node/loop_node.py
+++ b/apps/application/workflow/nodes/loop_node/loop_node.py
@@ -133,6 +133,7 @@ def on_complete(wf_manage, error):
 
             if error:
                 self.write_context("error_message", str(error))
+                self.complete(Status.FAIL, error=error)
                 return
 
             self._run_next()