File tree Expand file tree Collapse file tree 1 file changed +17
-5
lines changed Expand file tree Collapse file tree 1 file changed +17
-5
lines changed Original file line number Diff line number Diff line change 27
27
Queue : "test" ,
28
28
Retries : 3 ,
29
29
}}
30
+ group = models.GroupReq {
31
+ GroupID : "testgroup" ,
32
+ Jobs : []models.JobReq {
33
+ {
34
+ JobID : "job1_group" ,
35
+ TaskName : "get_profit_summary" ,
36
+ Queue : "test" ,
37
+ Retries : 4 ,
38
+ }, {
39
+ JobID : "job2_group" ,
40
+ TaskName : "get_profit_summary" ,
41
+ Queue : "test" ,
42
+ Retries : 3 ,
43
+ }},
44
+ }
30
45
31
46
jobsPending = []models.JobReq {{
32
47
JobID : "job3" ,
@@ -146,13 +161,10 @@ func TestDeleteJob(t *testing.T) {
146
161
}
147
162
148
163
func TestPostJobGroup (t * testing.T ) {
149
- _ , err := cl .PostJobGroup (models.GroupReq {
150
- GroupID : "testgroup" ,
151
- Jobs : jobs ,
152
- })
164
+ _ , err := cl .PostJobGroup (group )
153
165
assert .NoError (t , err , "error posting job group" )
154
166
}
155
167
func TestGetJobGroupStatus (t * testing.T ) {
156
- _ , err := cl .GetGroupStatus ("testgroup" )
168
+ _ , err := cl .GetGroupStatus (group . GroupID )
157
169
assert .NoError (t , err , "error getting job group status" )
158
170
}
You can’t perform that action at this time.
0 commit comments