diff options
Diffstat (limited to 'scheduler/worker_pool.go')
| -rw-r--r-- | scheduler/worker_pool.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/scheduler/worker_pool.go b/scheduler/worker_pool.go index b753f89..c4a8372 100644 --- a/scheduler/worker_pool.go +++ b/scheduler/worker_pool.go @@ -14,9 +14,11 @@ type WorkerPool struct { queue chan model.Job } -// Push send a job on the queue. -func (w *WorkerPool) Push(job model.Job) { - w.queue <- job +// Push send a list of jobs to the queue. +func (w *WorkerPool) Push(jobs model.JobList) { + for _, job := range jobs { + w.queue <- job + } } // NewWorkerPool creates a pool of background workers. |