diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-23 01:08:03 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-23 01:08:03 +0300 |
| commit | ed36f3ef0d18354ab18848aae488d139aefd1146 (patch) | |
| tree | 4be15333849a2214c0b1d0b7168f8735a1093456 /plugins/jobs/drivers/beanstalk | |
| parent | 71e3b0f5f7f68a443f7b1e155c91e12f692dedbc (diff) | |
Remove completed TODOs from the beanstalk driver.
Rename pipeline_size -> prefetch for the ephemeral driver. Limit number
of active goroutines (delay's) to 1000.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/drivers/beanstalk')
| -rw-r--r-- | plugins/jobs/drivers/beanstalk/consumer.go | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/beanstalk/consumer.go b/plugins/jobs/drivers/beanstalk/consumer.go index ab5aad14..32ce6ef7 100644 --- a/plugins/jobs/drivers/beanstalk/consumer.go +++ b/plugins/jobs/drivers/beanstalk/consumer.go @@ -180,7 +180,6 @@ func (j *JobConsumer) Push(jb *job.Job) error { // increase the ttr to 1. Maximum ttr is 2**32-1. id, err := j.pool.Put(bb.Bytes(), 0, item.Options.DelayDuration(), item.Options.TimeoutDuration()) if err != nil { - // TODO check for the connection error errD := j.pool.Delete(id) if errD != nil { return errors.E(op, errors.Errorf("%s:%s", err.Error(), errD.Error())) |