diff options
Diffstat (limited to 'plugins/jobs')
| -rw-r--r-- | plugins/jobs/drivers/amqp/rabbit_init.go | 8 | ||||
| -rw-r--r-- | plugins/jobs/plugin.go | 2 |
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()) } } } |