Update beanstalk options. Fix tube priority (correctly pass to the Put

method).

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

2 files changed, 12 insertions, 21 deletions

diff --git a/tests/plugins/jobs/beanstalk/.rr-beanstalk-init.yaml b/tests/plugins/jobs/beanstalk/.rr-beanstalk-init.yaml
index 5ca45b7d..c73ed961 100644
--- a/tests/plugins/jobs/beanstalk/.rr-beanstalk-init.yaml
+++ b/tests/plugins/jobs/beanstalk/.rr-beanstalk-init.yaml
@@ -28,28 +28,18 @@ jobs:
 
   pipelines:
     test-1:
-      driver: amqp
-      prefetch: 100
-      queue: test-1-queue
-      priority: 1
-      exchange: default
-      exchange_type: direct
-      routing_key: test-1
-      exclusive: false
-      multiple_ack: false
-      requeue_on_fail: false
+      driver: beanstalk
+      priority: 11
+      tube_priority: 1
+      tube: default-1
+      reserve_timeout: 10s
 
     test-2:
-      driver: amqp
-      prefetch: 100
-      queue: test-2-queue
-      priority: 2
-      exchange: default
-      exchange_type: direct
-      routing_key: test-2
-      exclusive: false
-      multiple_ack: false
-      requeue_on_fail: false
+      driver: beanstalk
+      priority: 11
+      tube_priority: 3
+      tube: default-2
+      reserve_timeout: 10s
 
 
   # list of pipelines to be consumed by the server, keep empty if you want to start consuming manually
diff --git a/tests/plugins/jobs/jobs_beanstalk_test.go b/tests/plugins/jobs/jobs_beanstalk_test.go
index 44d4f85e..d3e0dd2a 100644
--- a/tests/plugins/jobs/jobs_beanstalk_test.go
+++ b/tests/plugins/jobs/jobs_beanstalk_test.go
@@ -224,9 +224,10 @@ func declareBeanstalkPipe(t *testing.T) {
 	pipe := &jobsv1beta.DeclareRequest{Pipeline: map[string]string{
 		"driver":          "beanstalk",
 		"name":            "test-3",
-		"tube":            "default",
+		"tube":            "default-" + time.Now().String(),
 		"reserve_timeout": "1",
 		"priority":        "3",
+		"tube_priority":   "10",
 	}}
 
 	er := &jobsv1beta.Empty{}