summaryrefslogtreecommitdiff
path: root/plugins/jobs/drivers/sqs/consumer.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/drivers/sqs/consumer.go')
-rw-r--r--plugins/jobs/drivers/sqs/consumer.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/sqs/consumer.go b/plugins/jobs/drivers/sqs/consumer.go
index 246ff3ba..1ded5bc9 100644
--- a/plugins/jobs/drivers/sqs/consumer.go
+++ b/plugins/jobs/drivers/sqs/consumer.go
@@ -297,7 +297,7 @@ func (j *JobConsumer) Run(p *pipeline.Pipeline) error {
go j.listen()
j.eh.Push(events.JobEvent{
- Event: events.EventPipeRun,
+ Event: events.EventPipeActive,
Driver: pipe.Driver(),
Pipeline: pipe.Name(),
Start: time.Now(),