diff options
| -rw-r--r-- | plugins/jobs/config.go | 2 | ||||
| -rw-r--r-- | plugins/jobs/drivers/sqs/listener.go | 2 | ||||
| -rw-r--r-- | plugins/jobs/plugin.go | 2 | ||||
| -rw-r--r-- | tests/plugins/jobs/durability/.rr-sqs-durability-redial.yaml | 1 |
4 files changed, 4 insertions, 3 deletions
diff --git a/plugins/jobs/config.go b/plugins/jobs/config.go index dfcfcb95..454256b9 100644 --- a/plugins/jobs/config.go +++ b/plugins/jobs/config.go @@ -55,7 +55,7 @@ func (c *Config) InitDefaults() { } if c.Timeout == 0 { - c.Timeout = 10 + c.Timeout = 60 } c.Pool.InitDefaults() diff --git a/plugins/jobs/drivers/sqs/listener.go b/plugins/jobs/drivers/sqs/listener.go index b72ac065..a283b4a3 100644 --- a/plugins/jobs/drivers/sqs/listener.go +++ b/plugins/jobs/drivers/sqs/listener.go @@ -46,7 +46,7 @@ func (j *JobConsumer) listen(ctx context.Context) { //nolint:gocognit j.log.Error("create queue", "error", err) } // To successfully create a new queue, you must provide a - // queue name that adheres to the limits related to queues + // queue name that adheres to the limits related to the queues // (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/limits-queues.html) // and is unique within the scope of your queues. After you create a queue, you // must wait at least one second after the queue is created to be able to use the <------------ diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go index c9bba1c2..8ea18cfd 100644 --- a/plugins/jobs/plugin.go +++ b/plugins/jobs/plugin.go @@ -354,7 +354,7 @@ func (p *Plugin) Push(j *job.Job) error { } // if job has no priority, inherit it from the pipeline - // TODO merge all options, not only priority + // TODO(rustatian) merge all options, not only priority if j.Options.Priority == 0 { j.Options.Priority = ppl.Priority() } diff --git a/tests/plugins/jobs/durability/.rr-sqs-durability-redial.yaml b/tests/plugins/jobs/durability/.rr-sqs-durability-redial.yaml index 8f1a1d5d..b6ba83a4 100644 --- a/tests/plugins/jobs/durability/.rr-sqs-durability-redial.yaml +++ b/tests/plugins/jobs/durability/.rr-sqs-durability-redial.yaml @@ -22,6 +22,7 @@ jobs: pipeline_size: 100000 pool: num_workers: 10 + timeout: 20 max_jobs: 0 allocate_timeout: 60s destroy_timeout: 60s |