diff options
Diffstat (limited to 'plugins/jobs/config.go')
-rw-r--r-- | plugins/jobs/config.go | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/plugins/jobs/config.go b/plugins/jobs/config.go index 1b613231..dfcfcb95 100644 --- a/plugins/jobs/config.go +++ b/plugins/jobs/config.go @@ -23,6 +23,9 @@ type Config struct { // Driver pipeline might be much larger than a main jobs queue PipelineSize uint64 `mapstructure:"pipeline_size"` + // Timeout in seconds is the per-push limit to put the job into queue + Timeout int `mapstructure:"timeout"` + // Pool configures roadrunner workers pool. Pool *poolImpl.Config `mapstructure:"Pool"` @@ -51,5 +54,9 @@ func (c *Config) InitDefaults() { c.Pipelines[k].With(pipelineName, k) } + if c.Timeout == 0 { + c.Timeout = 10 + } + c.Pool.InitDefaults() } |