File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
apps/sim/app/workspace/[workspaceId]/w/[workflowId]/hooks Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -1388,6 +1388,7 @@ export function useWorkflowExecution() {
13881388 onExecutionCompleted : ( data ) => {
13891389 if (
13901390 activeWorkflowId &&
1391+ executionIdRef . current &&
13911392 useExecutionStore . getState ( ) . getCurrentExecutionId ( activeWorkflowId ) !==
13921393 executionIdRef . current
13931394 )
@@ -1459,6 +1460,7 @@ export function useWorkflowExecution() {
14591460 onExecutionError : ( data ) => {
14601461 if (
14611462 activeWorkflowId &&
1463+ executionIdRef . current &&
14621464 useExecutionStore . getState ( ) . getCurrentExecutionId ( activeWorkflowId ) !==
14631465 executionIdRef . current
14641466 )
@@ -1492,6 +1494,7 @@ export function useWorkflowExecution() {
14921494 onExecutionCancelled : ( data ) => {
14931495 if (
14941496 activeWorkflowId &&
1497+ executionIdRef . current &&
14951498 useExecutionStore . getState ( ) . getCurrentExecutionId ( activeWorkflowId ) !==
14961499 executionIdRef . current
14971500 )
@@ -2196,6 +2199,7 @@ export function useWorkflowExecution() {
21962199 } )
21972200 . catch ( ( error ) => {
21982201 logger . warn ( 'Execution reconnection failed' , { executionId, error } )
2202+ clearExecutionEntries ( executionId )
21992203 for ( const entry of runningEntries . filter ( ( e ) => e . executionId === executionId ) ) {
22002204 addConsole ( {
22012205 workflowId : entry . workflowId ,
You can’t perform that action at this time.
0 commit comments