From 13bc68a646fe8bed96d3f2e7671ad5ec5f2fdd4f Mon Sep 17 00:00:00 2001
From: zhsama <torvalds@linux.do>
Date: Wed, 29 Oct 2025 00:07:08 +0800
Subject: [PATCH] feat(trigger): enhance runScheduleSingleRun to handle API
 response

---
 .../nodes/_base/hooks/use-one-step-run.ts     | 62 +++++++++++++++----
 1 file changed, 49 insertions(+), 13 deletions(-)

diff --git a/web/app/components/workflow/nodes/_base/hooks/use-one-step-run.ts b/web/app/components/workflow/nodes/_base/hooks/use-one-step-run.ts
index 1b27c497a8..4ca99129cc 100644
--- a/web/app/components/workflow/nodes/_base/hooks/use-one-step-run.ts
+++ b/web/app/components/workflow/nodes/_base/hooks/use-one-step-run.ts
@@ -392,17 +392,51 @@ const useOneStepRun = <T>({
     setListeningTriggerIsAll,
   ])
 
-  const runScheduleSingleRun = useCallback(async (): Promise<any | null> => {
-    handleNodeDataUpdate({
-      id,
-      data: {
-        ...data,
-        _isSingleRun: false,
-        _singleRunningStatus: NodeRunningStatus.Listening,
-      },
-    })
-    return {}
-  }, [handleNodeDataUpdate])
+  const runScheduleSingleRun = useCallback(async (): Promise<NodeRunResult | null> => {
+    const urlPath = `/apps/${flowId}/workflows/draft/nodes/${id}/trigger/run`
+
+    try {
+      const response: any = await post(urlPath, {
+        body: JSON.stringify({}),
+      })
+
+      if (!response) {
+        const message = 'Schedule trigger run failed'
+        Toast.notify({ type: 'error', message })
+        throw new Error(message)
+      }
+
+      if (response?.status === 'error') {
+        const message = response?.message || 'Schedule trigger run failed'
+        Toast.notify({ type: 'error', message })
+        throw new Error(message)
+      }
+
+      handleNodeDataUpdate({
+        id,
+        data: {
+          ...data,
+          _isSingleRun: false,
+          _singleRunningStatus: NodeRunningStatus.Succeeded,
+        },
+      })
+
+      return response as NodeRunResult
+    }
+    catch (error) {
+      console.error('handleRun: schedule trigger single run error', error)
+      handleNodeDataUpdate({
+        id,
+        data: {
+          ...data,
+          _isSingleRun: false,
+          _singleRunningStatus: NodeRunningStatus.Failed,
+        },
+      })
+      Toast.notify({ type: 'error', message: 'Schedule trigger run failed' })
+      throw error
+    }
+  }, [flowId, id, handleNodeDataUpdate, data])
 
   const runWebhookSingleRun = useCallback(async (): Promise<any | null> => {
     const urlPath = `/apps/${flowId}/workflows/draft/nodes/${id}/trigger/run`
@@ -656,7 +690,9 @@ const useOneStepRun = <T>({
       data: {
         ...data,
         _isSingleRun: false,
-        _singleRunningStatus: isTriggerNode ? NodeRunningStatus.Listening : NodeRunningStatus.Running,
+        _singleRunningStatus: isTriggerNode
+          ? NodeRunningStatus.Listening
+          : NodeRunningStatus.Running,
       },
     })
     let res: any
@@ -664,7 +700,7 @@ const useOneStepRun = <T>({
     try {
       if (!isIteration && !isLoop) {
         if (isScheduleTriggerNode) {
-          await runScheduleSingleRun()
+          res = await runScheduleSingleRun()
         }
         else if (isWebhookTriggerNode) {
           res = await runWebhookSingleRun()