summaryrefslogtreecommitdiff
path: root/plugins/jobs/drivers/ephemeral/consumer.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/drivers/ephemeral/consumer.go')
-rw-r--r--plugins/jobs/drivers/ephemeral/consumer.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/ephemeral/consumer.go b/plugins/jobs/drivers/ephemeral/consumer.go
index 71652066..ff8f7860 100644
--- a/plugins/jobs/drivers/ephemeral/consumer.go
+++ b/plugins/jobs/drivers/ephemeral/consumer.go
@@ -185,7 +185,7 @@ func (j *JobBroker) Resume(pipeline string) {
// Run is no-op for the ephemeral
func (j *JobBroker) Run(pipe *pipeline.Pipeline) error {
j.eh.Push(events.JobEvent{
- Event: events.EventPipeRun,
+ Event: events.EventPipeActive,
Driver: pipe.Driver(),
Pipeline: pipe.Name(),
Start: time.Now(),