diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-05 11:52:03 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-05 11:52:03 +0300 |
| commit | 1dd43e378c55b6984bda6c2e8b048d2ed821aa43 (patch) | |
| tree | d7167b35ea675696d4cf2ef2b76d1ecdda98a0f9 /plugins/jobs | |
| parent | 677db79f76fcc566bee2b1b51d0f40a0c9f2ac19 (diff) | |
- Finish binary_heap
Signed-off-by: Valery Piashchynski <[email protected]>
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) } } |