Initial tests for all drivers

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

1 files changed, 1 insertions, 14 deletions

diff --git a/tests/plugins/jobs/jobs_amqp_test.go b/tests/plugins/jobs/jobs_amqp_test.go
index 52bb6c7c..a95ac98b 100644
--- a/tests/plugins/jobs/jobs_amqp_test.go
+++ b/tests/plugins/jobs/jobs_amqp_test.go
@@ -205,7 +205,7 @@ func TestAMQPDeclare(t *testing.T) {
 	time.Sleep(time.Second * 3)
 
 	t.Run("DeclareAMQPPipeline", declareAMQPPipe)
-	t.Run("ConsumeAMQPPipeline", consumeAMQPPipe)
+	t.Run("ConsumeAMQPPipeline", resumePipes("test-3"))
 	t.Run("PushAMQPPipeline", pushToPipe("test-3"))
 	t.Run("PauseAMQPPipeline", pausePipelines("test-3"))
 	t.Run("DestroyAMQPPipeline", destroyPipelines("test-3"))
@@ -238,16 +238,3 @@ func declareAMQPPipe(t *testing.T) {
 	err = client.Call("jobs.Declare", pipe, er)
 	assert.NoError(t, err)
 }
-
-func consumeAMQPPipe(t *testing.T) {
-	conn, err := net.Dial("tcp", "127.0.0.1:6001")
-	assert.NoError(t, err)
-	client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn))
-
-	pipe := &jobsv1beta.Pipelines{Pipelines: make([]string, 1)}
-	pipe.GetPipelines()[0] = "test-3"
-
-	er := &jobsv1beta.Empty{}
-	err = client.Call("jobs.Resume", pipe, er)
-	assert.NoError(t, err)
-}