diff options
Diffstat (limited to 'tests/plugins/jobs')
| -rw-r--r-- | tests/plugins/jobs/configs/.rr-jobs-init.yaml | 7 | ||||
| -rw-r--r-- | tests/plugins/jobs/jobs_plugin_test.go | 2 |
2 files changed, 6 insertions, 3 deletions
diff --git a/tests/plugins/jobs/configs/.rr-jobs-init.yaml b/tests/plugins/jobs/configs/.rr-jobs-init.yaml index 6ff2ab70..93c978c2 100644 --- a/tests/plugins/jobs/configs/.rr-jobs-init.yaml +++ b/tests/plugins/jobs/configs/.rr-jobs-init.yaml @@ -23,6 +23,9 @@ sqs: declare: MessageRetentionPeriod: 86400 +logs: + level: debug + mode: development jobs: # num logical cores by default @@ -65,7 +68,7 @@ jobs: test-2-amqp: driver: amqp priority: 2 - pipeline_size: 1000 + pipeline_size: 100000 queue: test-2-queue exchange: default exchange_type: direct @@ -85,5 +88,5 @@ jobs: queue: default # list of pipelines to be consumed by the server, keep empty if you want to start consuming manually - consume: [ "test-local", "test-local-2", "test-local-3", "test-1" ] + consume: [ "test-local", "test-local-2", "test-local-3", "test-1", "test-2-amqp" ] diff --git a/tests/plugins/jobs/jobs_plugin_test.go b/tests/plugins/jobs/jobs_plugin_test.go index b2f05f0f..76b7b879 100644 --- a/tests/plugins/jobs/jobs_plugin_test.go +++ b/tests/plugins/jobs/jobs_plugin_test.go @@ -84,7 +84,7 @@ func TestJobsInit(t *testing.T) { } }() - time.Sleep(time.Second * 120) + time.Sleep(time.Second * 1200) stopCh <- struct{}{} |