diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-23 01:08:03 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-23 01:08:03 +0300 |
| commit | ed36f3ef0d18354ab18848aae488d139aefd1146 (patch) | |
| tree | 4be15333849a2214c0b1d0b7168f8735a1093456 /tests/plugins | |
| parent | 71e3b0f5f7f68a443f7b1e155c91e12f692dedbc (diff) | |
Remove completed TODOs from the beanstalk driver.
Rename pipeline_size -> prefetch for the ephemeral driver. Limit number
of active goroutines (delay's) to 1000.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins')
| -rw-r--r-- | tests/plugins/jobs/jobs_ephemeral_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/tests/plugins/jobs/jobs_ephemeral_test.go b/tests/plugins/jobs/jobs_ephemeral_test.go index e8974a59..37e25970 100644 --- a/tests/plugins/jobs/jobs_ephemeral_test.go +++ b/tests/plugins/jobs/jobs_ephemeral_test.go @@ -222,9 +222,9 @@ func declareEphemeralPipe(t *testing.T) { client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn)) pipe := &jobsv1beta.DeclareRequest{Pipeline: map[string]string{ - "driver": "ephemeral", - "name": "test-3", - "pipeline_size": "10000", + "driver": "ephemeral", + "name": "test-3", + "prefetch": "10000", }} er := &jobsv1beta.Empty{} |