@@ -293,20 +293,19 @@ export const checkNodeRunStatus = ({
293293 node : RuntimeNodeItemType ;
294294 runtimeEdges : RuntimeEdgeItemType [ ] ;
295295} ) => {
296- const filterRuntimeEdges = filterWorkflowEdges ( runtimeEdges ) ;
297-
298296 const isStartNode = ( nodeType : string ) => {
299297 const map : Record < any , boolean > = {
300298 [ FlowNodeTypeEnum . workflowStart ] : true ,
301- [ FlowNodeTypeEnum . pluginInput ] : true
299+ [ FlowNodeTypeEnum . pluginInput ] : true ,
300+ [ FlowNodeTypeEnum . loopStart ] : true
302301 } ;
303302 return ! ! map [ nodeType ] ;
304303 } ;
305304 const splitNodeEdges = ( targetNode : RuntimeNodeItemType ) => {
306305 const commonEdges : RuntimeEdgeItemType [ ] = [ ] ;
307306 const recursiveEdgeGroupsMap = new Map < string , RuntimeEdgeItemType [ ] > ( ) ;
308307
309- const sourceEdges = filterRuntimeEdges . filter ( ( item ) => item . target === targetNode . nodeId ) ;
308+ const sourceEdges = runtimeEdges . filter ( ( item ) => item . target === targetNode . nodeId ) ;
310309
311310 sourceEdges . forEach ( ( sourceEdge ) => {
312311 const stack : Array < {
@@ -349,7 +348,7 @@ export const checkNodeRunStatus = ({
349348 newVisited . add ( edge . source ) ;
350349
351350 // 查找目标节点的 source edges 并加入栈中
352- const nextEdges = filterRuntimeEdges . filter ( ( item ) => item . target === edge . source ) ;
351+ const nextEdges = runtimeEdges . filter ( ( item ) => item . target === edge . source ) ;
353352 for ( const nextEdge of nextEdges ) {
354353 stack . push ( {
355354 edge : nextEdge ,
@@ -364,7 +363,8 @@ export const checkNodeRunStatus = ({
364363
365364 // Classify edges
366365 const { commonEdges, recursiveEdgeGroups } = splitNodeEdges ( node ) ;
367-
366+ console . log ( node . name ) ;
367+ console . log ( JSON . stringify ( { commonEdges, recursiveEdgeGroups } , null , 2 ) ) ;
368368 // Entry
369369 if ( commonEdges . length === 0 && recursiveEdgeGroups . length === 0 ) {
370370 return 'run' ;
0 commit comments