summaryrefslogtreecommitdiff
path: root/plugins
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-08-11 12:34:19 +0300
committerValery Piashchynski <[email protected]>2021-08-11 12:34:19 +0300
commitaeb7d301eefc1c47374ab9b758ea137151e29219 (patch)
tree7e2b7cbe0b18251c0d742a9310a7d677e13712a0 /plugins
parent3e2e9fbd9650c44d57a41a9dc702fe93aad2b77f (diff)
Increase timeout to 60s.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins')
-rw-r--r--plugins/jobs/config.go2
-rw-r--r--plugins/jobs/drivers/sqs/listener.go2
-rw-r--r--plugins/jobs/plugin.go2
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()
}