Remove unused code

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 0 insertions, 27 deletions

diff --git a/tests/plugins/jobs/helpers.go b/tests/plugins/jobs/helpers.go
index d8c32a49..27b2d1e0 100644
--- a/tests/plugins/jobs/helpers.go
+++ b/tests/plugins/jobs/helpers.go
@@ -81,33 +81,6 @@ func pushToPipe(pipeline string) func(t *testing.T) {
 	}
 }
 
-func pushToPipeExpectErr(pipeline string) func(t *testing.T) {
-	return func(t *testing.T) {
-		conn, err := net.Dial("tcp", "127.0.0.1:6001")
-		assert.NoError(t, err)
-		client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn))
-
-		req := &jobsv1beta.PushRequest{Job: &jobsv1beta.Job{
-			Job:     "some/php/namespace",
-			Id:      "1",
-			Payload: `{"hello":"world"}`,
-			Headers: map[string]*jobsv1beta.HeaderValue{"test": {Value: []string{"test2"}}},
-			Options: &jobsv1beta.Options{
-				Priority:   1,
-				Pipeline:   pipeline,
-				Delay:      0,
-				Attempts:   0,
-				RetryDelay: 0,
-				Timeout:    0,
-			},
-		}}
-
-		er := &jobsv1beta.Empty{}
-		err = client.Call("jobs.Push", req, er)
-		require.Error(t, err)
-	}
-}
-
 func pausePipelines(pipes ...string) func(t *testing.T) {
 	return func(t *testing.T) {
 		conn, err := net.Dial("tcp", "127.0.0.1:6001")