From 9c51360f9119a4114bdcc21c8e61f0908a3c876d Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Sun, 18 Jul 2021 11:32:44 +0300 Subject: Started beanstalk driver. Add new Queue impl (not finished yet). Fix bugs in the AMQP, update proto-api Signed-off-by: Valery Piashchynski --- plugins/jobs/plugin.go | 2 ++ 1 file changed, 2 insertions(+) (limited to 'plugins/jobs/plugin.go') 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 -- cgit v1.2.3