Skip to content

Commit 01cdcf9

Browse files
committed
Fixed a subflow startnode issue where it would track the wrong startnode
1 parent 8ba7936 commit 01cdcf9

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

shared.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21755,10 +21755,10 @@ func PrepareWorkflowExecution(ctx context.Context, workflow Workflow, request *h
2175521755
}
2175621756

2175721757
// Validation of SKIPPED nodes
21758-
if len(workflowExecution.Workflow.Start) > 0 {
21759-
childNodes := FindChildNodes(workflowExecution.Workflow, workflow.Start, []string{}, []string{})
21758+
if len(workflowExecution.Start) > 0 {
21759+
childNodes := FindChildNodes(workflowExecution.Workflow, workflowExecution.Start, []string{}, []string{})
2176021760

21761-
//log.Printf("\n\n\n[DEBUG][%s] STARTUP NODES (%d): %#v. Total actions: %#v\n\n\n", workflowExecution.ExecutionId, len(childNodes), childNodes, len(workflowExecution.Workflow.Actions))
21761+
//log.Printf("\n\n\n[DEBUG][%s] STARTUP NODES UNDER '%s' (%d): %#v. Total actions: %#v\n\n\n", workflowExecution.ExecutionId, workflowExecution.Start, len(childNodes), childNodes, len(workflowExecution.Workflow.Actions))
2176221762

2176321763
for _, action := range workflowExecution.Workflow.Actions {
2176421764
if action.ID == workflowExecution.Start {

streaming.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -226,3 +226,4 @@ func HandleStreamWorkflow(resp http.ResponseWriter, request *http.Request) {
226226
time.Sleep(100 * time.Millisecond)
227227
}
228228
}
229+

0 commit comments

Comments
 (0)