|
|
@@ -27,6 +27,8 @@ func (p *Pipeline) Run(globalRunParams map[string]any, dynamicParams map[string]
|
|
|
token := NewRunToken()
|
|
|
|
|
|
go func() {
|
|
|
+ defer token.Done()
|
|
|
+
|
|
|
result, err := p.Flow.Run(&component.GlobalRunParams{
|
|
|
CustomRunParams: globalRunParams,
|
|
|
}, dynamicParams)
|
|
|
@@ -36,7 +38,6 @@ func (p *Pipeline) Run(globalRunParams map[string]any, dynamicParams map[string]
|
|
|
}
|
|
|
|
|
|
token.Result = result
|
|
|
- token.Done()
|
|
|
}()
|
|
|
|
|
|
return token
|
