Update go.mod dependencies to the most recent version.

Fix tests according to the new mocks.

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

2 files changed, 0 insertions, 10 deletions

diff --git a/plugins/jobs/drivers/amqp/rabbit_init.go b/plugins/jobs/drivers/amqp/rabbit_init.go
index 570498e9..56ef10c8 100644
--- a/plugins/jobs/drivers/amqp/rabbit_init.go
+++ b/plugins/jobs/drivers/amqp/rabbit_init.go
@@ -1,10 +1,7 @@
 package amqp
 
 import (
-	"time"
-
 	"github.com/spiral/errors"
-	"github.com/spiral/roadrunner/v2/pkg/events"
 )
 
 func (j *JobConsumer) initRabbitMQ() error {
@@ -56,10 +53,5 @@ func (j *JobConsumer) initRabbitMQ() error {
 		return errors.E(op, err)
 	}
 
-	j.eh.Push(events.JobEvent{
-		Event:  events.EventInitialized,
-		Driver: "amqp",
-		Start:  time.Now(),
-	})
 	return channel.Close()
 }
diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go
index 26015516..7707cb8a 100644
--- a/plugins/jobs/plugin.go
+++ b/plugins/jobs/plugin.go
@@ -553,8 +553,6 @@ func (p *Plugin) collectJobsEvents(event interface{}) {
 			p.log.Error("pipeline error", "pipeline", jev.Pipeline, "error", jev.Error, "start", jev.Start.UTC(), "elapsed", jev.Elapsed)
 		case events.EventDriverReady:
 			p.log.Info("driver ready", "pipeline", jev.Pipeline, "start", jev.Start.UTC(), "elapsed", jev.Elapsed)
-		case events.EventInitialized:
-			p.log.Info("driver initialized", "driver", jev.Driver, "start", jev.Start.UTC())
 		}
 	}
 }