diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-18 11:32:44 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-18 11:32:44 +0300 |
| commit | 9c51360f9119a4114bdcc21c8e61f0908a3c876d (patch) | |
| tree | ea63a051931bbd8282d64478bbefa2f970fcc955 /plugins/jobs/plugin.go | |
| parent | f4feb30197843d05eb308081ee579d3a9e3d6206 (diff) | |
Started beanstalk driver. Add new Queue impl (not finished yet).
Fix bugs in the AMQP, update proto-api
Signed-off-by: Valery Piashchynski <[email protected]>
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 |