diff options
Diffstat (limited to 'plugins/jobs/plugin.go')
| -rw-r--r-- | plugins/jobs/plugin.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go index f71c2718..98e7ebf8 100644 --- a/plugins/jobs/plugin.go +++ b/plugins/jobs/plugin.go @@ -432,6 +432,7 @@ func (p *Plugin) Declare(pipeline *pipeline.Pipeline) error { } // if pipeline initialized to be consumed, call Run on it + // but likely for the dynamic pipelines it should be started manually if _, ok := p.consume[pipeline.Name()]; ok { err = initializedDriver.Run(pipeline) if err != nil { @@ -440,6 +441,7 @@ func (p *Plugin) Declare(pipeline *pipeline.Pipeline) error { } } + // save the pipeline p.pipelines.Store(pipeline.Name(), pipeline) return nil |