diff options
author | Valery Piashchynski <[email protected]> | 2021-08-11 12:34:19 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-08-11 12:34:19 +0300 |
commit | aeb7d301eefc1c47374ab9b758ea137151e29219 (patch) | |
tree | 7e2b7cbe0b18251c0d742a9310a7d677e13712a0 /plugins | |
parent | 3e2e9fbd9650c44d57a41a9dc702fe93aad2b77f (diff) |
Increase timeout to 60s.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins')
-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 |
3 files changed, 3 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() } |