Remove duplicated logging

Signed-off-by: Valery Piashchynski <[email protected]>

2 files changed, 2 insertions, 22 deletions

diff --git a/plugins/jobs/drivers/ephemeral/consumer.go b/plugins/jobs/drivers/ephemeral/consumer.go
index 45ee8083..cd08ca7a 100644
--- a/plugins/jobs/drivers/ephemeral/consumer.go
+++ b/plugins/jobs/drivers/ephemeral/consumer.go
@@ -152,7 +152,7 @@ func (j *JobBroker) Pause(pipeline string) {
 func (j *JobBroker) Resume(pipeline string) {
 	if q, ok := j.pipeline.Load(pipeline); ok {
 		if q == false {
-			// mark pipeline as turned off
+			// mark pipeline as turned on
 			j.pipeline.Store(pipeline, true)
 		}
 	}
@@ -165,18 +165,6 @@ func (j *JobBroker) Resume(pipeline string) {
 	})
 }
 
-func (j *JobBroker) List() []string {
-	out := make([]string, 0, 2)
-
-	j.pipeline.Range(func(key, value interface{}) bool {
-		pipe := key.(string)
-		out = append(out, pipe)
-		return true
-	})
-
-	return out
-}
-
 // Run is no-op for the ephemeral
 func (j *JobBroker) Run(_ *pipeline.Pipeline) error {
 	return nil
diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go
index ce51df21..f71c2718 100644
--- a/plugins/jobs/plugin.go
+++ b/plugins/jobs/plugin.go
@@ -142,20 +142,12 @@ func (p *Plugin) Serve() chan error { //nolint:gocognit
 					errCh <- errors.E(op, err)
 					return false
 				}
-
-				p.events.Push(events.JobEvent{
-					Event:    events.EventPipeRun,
-					Pipeline: pipe.Name(),
-					Driver:   pipe.Driver(),
-					Start:    t,
-					Elapsed:  t.Sub(t),
-				})
-
 				return true
 			}
 
 			return true
 		}
+
 		p.events.Push(events.JobEvent{
 			Event:    events.EventDriverReady,
 			Pipeline: pipe.Name(),