summaryrefslogtreecommitdiff
path: root/tests/plugins/jobs/jobs_beanstalk_test.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-23 01:25:12 +0300
committerValery Piashchynski <[email protected]>2021-07-23 01:25:12 +0300
commit3f45d2c008c95daa923fef0c4c9022b2be462971 (patch)
treeedb88b5470c448da2647715633f383d98818c7fb /tests/plugins/jobs/jobs_beanstalk_test.go
parented36f3ef0d18354ab18848aae488d139aefd1146 (diff)
Update beanstalk options. Fix tube priority (correctly pass to the Put
method). Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins/jobs/jobs_beanstalk_test.go')
-rw-r--r--tests/plugins/jobs/jobs_beanstalk_test.go3
1 files changed, 2 insertions, 1 deletions
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{}