fix possible multiple inputs error

173409900 · Aug 25, 2016 · 672d457 · 672d457
1 parent 83e45eb
commit 672d457
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flow/context_run.go b/flow/context_run.go
@@ -78,10 +78,10 @@ func (fc *FlowContext) runFlowContextInStandAloneMode() {
 		for _, input := range step.Inputs {
 			if _, ok := isDatasetStarted[input.Id]; !ok {
 				wg.Add(1)
-				go func(step *Step) {
+				go func(input *Dataset, step *Step) {
 					defer wg.Done()
 					input.RunDatasetInStandAloneMode()
-				}(step)
+				}(input, step)
 				isDatasetStarted[input.Id] = true
 			}
 		}