@@ -36,7 +36,7 @@ class ListSubmissions(GraphQLRequest):
36
36
$limit: Int,
37
37
$orderBy: SUBMISSION_COLUMN_ENUM,
38
38
$desc: Boolean
39
-
39
+
40
40
){
41
41
submissions(
42
42
submissionIds: $submissionIds,
@@ -45,7 +45,7 @@ class ListSubmissions(GraphQLRequest):
45
45
limit: $limit
46
46
orderBy: $orderBy,
47
47
desc: $desc
48
-
48
+
49
49
){
50
50
submissions {
51
51
id
@@ -64,14 +64,14 @@ class ListSubmissions(GraphQLRequest):
64
64
"""
65
65
66
66
def __init__ (
67
- self ,
68
- * ,
69
- submission_ids : List [int ] = None ,
70
- workflow_ids : List [int ] = None ,
71
- filters : Union [Dict , SubmissionFilter ] = None ,
72
- limit : int = 1000 ,
73
- order_by : str = "ID" ,
74
- desc : bool = True ,
67
+ self ,
68
+ * ,
69
+ submission_ids : List [int ] = None ,
70
+ workflow_ids : List [int ] = None ,
71
+ filters : Union [Dict , SubmissionFilter ] = None ,
72
+ limit : int = 1000 ,
73
+ order_by : str = "ID" ,
74
+ desc : bool = True ,
75
75
):
76
76
super ().__init__ (
77
77
self .query ,
@@ -120,14 +120,8 @@ class GetSubmission(GraphQLRequest):
120
120
}
121
121
"""
122
122
123
- def __init__ (
124
- self ,
125
- submission_id : int ,
126
- ):
127
- super ().__init__ (
128
- self .query ,
129
- variables = {"submissionId" : submission_id },
130
- )
123
+ def __init__ (self , submission_id : int ):
124
+ super ().__init__ (self .query , variables = {"submissionId" : submission_id })
131
125
132
126
def process_response (self , response ) -> Submission :
133
127
return Submission (** (super ().process_response (response )["submission" ]))
@@ -161,11 +155,7 @@ class WaitForSubmissions(RequestChain):
161
155
}
162
156
"""
163
157
164
- def __init__ (
165
- self ,
166
- submission_ids : List [int ],
167
- timeout : Union [int , float ] = 60 ,
168
- ):
158
+ def __init__ (self , submission_ids : List [int ], timeout : Union [int , float ] = 60 ):
169
159
if not submission_ids :
170
160
raise IndicoInputError ("Please provide submission ids" )
171
161
@@ -180,8 +170,8 @@ def requests(self) -> List[Submission]:
180
170
yield self .status_getter ()
181
171
curr_time = 0
182
172
while (
183
- not all (self .status_check (s .status ) for s in self .previous )
184
- and curr_time <= self .timeout
173
+ not all (self .status_check (s .status ) for s in self .previous )
174
+ and curr_time <= self .timeout
185
175
):
186
176
yield self .status_getter ()
187
177
time .sleep (1 )
@@ -251,10 +241,7 @@ class GenerateSubmissionResult(GraphQLRequest):
251
241
252
242
def __init__ (self , submission : Union [int , Submission ]):
253
243
submission_id = submission if isinstance (submission , int ) else submission .id
254
- super ().__init__ (
255
- self .query ,
256
- variables = {"submissionId" : submission_id },
257
- )
244
+ super ().__init__ (self .query , variables = {"submissionId" : submission_id })
258
245
259
246
def process_response (self , response ) -> Job :
260
247
response = super ().process_response (response )["submissionResults" ]
@@ -288,11 +275,11 @@ class SubmissionResult(RequestChain):
288
275
previous : Submission = None
289
276
290
277
def __init__ (
291
- self ,
292
- submission : Union [int , Submission ],
293
- check_status : str = None ,
294
- wait : bool = False ,
295
- timeout : Union [int , float ] = 30 ,
278
+ self ,
279
+ submission : Union [int , Submission ],
280
+ check_status : str = None ,
281
+ wait : bool = False ,
282
+ timeout : Union [int , float ] = 30 ,
296
283
):
297
284
self .submission_id = (
298
285
submission if isinstance (submission , int ) else submission .id
@@ -315,8 +302,8 @@ def requests(self) -> Union[Job, str]:
315
302
if self .wait :
316
303
curr_time = 0
317
304
while (
318
- not self .status_check (self .previous .status )
319
- and curr_time <= self .timeout
305
+ not self .status_check (self .previous .status )
306
+ and curr_time <= self .timeout
320
307
):
321
308
yield GetSubmission (self .submission_id )
322
309
time .sleep (1 )
@@ -369,11 +356,11 @@ class SubmitReview(GraphQLRequest):
369
356
}
370
357
371
358
def __init__ (
372
- self ,
373
- submission : Union [int , Submission ],
374
- changes : Dict = None ,
375
- rejected : bool = False ,
376
- force_complete : bool = None ,
359
+ self ,
360
+ submission : Union [int , Submission ],
361
+ changes : Dict = None ,
362
+ rejected : bool = False ,
363
+ force_complete : bool = None ,
377
364
):
378
365
submission_id = submission if isinstance (submission , int ) else submission .id
379
366
if not changes and not rejected :
@@ -412,6 +399,7 @@ class RetrySubmission(GraphQLRequest):
412
399
Attributes:
413
400
submission_ids (List[int]): the given submission ids to retry.
414
401
"""
402
+
415
403
query = """
416
404
mutation retrySubmission($submissionIds:[Int]!){
417
405
retrySubmissions(submissionIds: $submissionIds){
@@ -433,10 +421,7 @@ def __init__(self, submission_ids: List[int]):
433
421
if submission_ids is None or len (submission_ids ) < 1 :
434
422
raise IndicoInputError ("You must specify submission ids" )
435
423
436
- super ().__init__ (
437
- self .query ,
438
- variables = {"submissionIds" : submission_ids },
439
- )
424
+ super ().__init__ (self .query , variables = {"submissionIds" : submission_ids })
440
425
441
426
def process_response (self , response ) -> List [Submission ]:
442
427
return [
0 commit comments