diff options
Diffstat (limited to 'tests/plugins/jobs/jobs_ephemeral_test.go')
| -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{} |