Remove duplicated logging

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

1 files changed, 1 insertions, 13 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