diff options
Diffstat (limited to 'plugins/jobs')
| -rw-r--r-- | plugins/jobs/brokers/ephemeral/broker.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/jobs/brokers/ephemeral/broker.go b/plugins/jobs/brokers/ephemeral/broker.go index 95f476a6..4d357c34 100644 --- a/plugins/jobs/brokers/ephemeral/broker.go +++ b/plugins/jobs/brokers/ephemeral/broker.go @@ -57,6 +57,6 @@ func (j *JobBroker) Register(pipeline *pipeline.Pipeline) error { func (j *JobBroker) serve() { for item := range j.jobs { // item should satisfy - j.pq.Push(item) + j.pq.Insert(item) } } |