From ed36f3ef0d18354ab18848aae488d139aefd1146 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Fri, 23 Jul 2021 01:08:03 +0300 Subject: 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 --- tests/plugins/jobs/jobs_ephemeral_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'tests') 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{} -- cgit v1.2.3