diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-18 11:32:44 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-18 11:32:44 +0300 |
| commit | 9c51360f9119a4114bdcc21c8e61f0908a3c876d (patch) | |
| tree | ea63a051931bbd8282d64478bbefa2f970fcc955 /tests/plugins | |
| parent | f4feb30197843d05eb308081ee579d3a9e3d6206 (diff) | |
Started beanstalk driver. Add new Queue impl (not finished yet).
Fix bugs in the AMQP, update proto-api
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins')
| -rw-r--r-- | tests/plugins/jobs/configs/.rr-jobs-test.yaml | 2 | ||||
| -rw-r--r-- | tests/plugins/jobs/jobs_plugin_test.go | 5 |
2 files changed, 3 insertions, 4 deletions
diff --git a/tests/plugins/jobs/configs/.rr-jobs-test.yaml b/tests/plugins/jobs/configs/.rr-jobs-test.yaml index ee72c2b7..6e2733dd 100644 --- a/tests/plugins/jobs/configs/.rr-jobs-test.yaml +++ b/tests/plugins/jobs/configs/.rr-jobs-test.yaml @@ -36,7 +36,7 @@ jobs: pipeline_size: 100000 # worker pool configuration pool: - num_workers: 10 + num_workers: 20 max_jobs: 0 allocate_timeout: 60s destroy_timeout: 60s diff --git a/tests/plugins/jobs/jobs_plugin_test.go b/tests/plugins/jobs/jobs_plugin_test.go index 9a13435b..59f55f3d 100644 --- a/tests/plugins/jobs/jobs_plugin_test.go +++ b/tests/plugins/jobs/jobs_plugin_test.go @@ -123,7 +123,6 @@ func TestJobsInit(t *testing.T) { mockLogger.EXPECT().Info("driver ready", "pipeline", "test-2", "start", gomock.Any(), "elapsed", gomock.Any()).Times(1) mockLogger.EXPECT().Info("driver ready", "pipeline", "test-3", "start", gomock.Any(), "elapsed", gomock.Any()).Times(1) - mockLogger.EXPECT().Info("pipeline started", "pipeline", "test-local-2", "start", gomock.Any(), "elapsed", gomock.Any()).Times(1) mockLogger.EXPECT().Info("pipeline started", "pipeline", "test-1", "start", gomock.Any(), "elapsed", gomock.Any()).Times(1) mockLogger.EXPECT().Info("pipeline started", "pipeline", "test-2-amqp", "start", gomock.Any(), "elapsed", gomock.Any()).Times(1) @@ -337,7 +336,7 @@ func ephemeralPause(t *testing.T) { assert.NoError(t, err) client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn)) - pipe := &jobsv1beta.MaintenanceRequest{Pipelines: make([]string, 1)} + pipe := &jobsv1beta.Maintenance{Pipelines: make([]string, 1)} pipe.GetPipelines()[0] = "test-local" er := &jobsv1beta.Empty{} @@ -350,7 +349,7 @@ func ephemeralResume(t *testing.T) { assert.NoError(t, err) client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn)) - pipe := &jobsv1beta.MaintenanceRequest{Pipelines: make([]string, 1)} + pipe := &jobsv1beta.Maintenance{Pipelines: make([]string, 1)} pipe.GetPipelines()[0] = "test-local" er := &jobsv1beta.Empty{} |