1 files changed, 8 insertions, 0 deletions
diff --git a/plugins/jobs/config.go b/plugins/jobs/config.go
index aa2da2dc..1b613231 100644
--- a/plugins/jobs/config.go
+++ b/plugins/jobs/config.go
@@ -19,6 +19,10 @@ type Config struct {
 	// Default - num logical cores
 	NumPollers uint8 `mapstructure:"num_pollers"`
 
+	// PipelineSize is the limit of a main jobs queue which consume Items from the drivers pipeline
+	// Driver pipeline might be much larger than a main jobs queue
+	PipelineSize uint64 `mapstructure:"pipeline_size"`
+
 	// Pool configures roadrunner workers pool.
 	Pool *poolImpl.Config `mapstructure:"Pool"`
 
@@ -34,6 +38,10 @@ func (c *Config) InitDefaults() {
 		c.Pool = &poolImpl.Config{}
 	}
 
+	if c.PipelineSize == 0 {
+		c.PipelineSize = 1_000_000
+	}
+
 	if c.NumPollers == 0 {
 		c.NumPollers = uint8(runtime.NumCPU())
 	}