|
6 | 6 |
|
7 | 7 | from indico.client import IndicoClient |
8 | 8 | from indico.errors import IndicoError, IndicoInputError |
9 | | -from indico.filters import SubmissionFilter |
| 9 | +from indico.filters import SubmissionFilter, SubmissionReviewFilter |
10 | 10 | from indico.queries import ( |
11 | 11 | GetSubmission, |
12 | 12 | JobStatus, |
@@ -323,6 +323,31 @@ def test_workflow_submission_auto_review( |
323 | 323 | assert submission.status == "COMPLETE" if force_complete else "PENDING_REVIEW" |
324 | 324 |
|
325 | 325 |
|
| 326 | +def test_list_workflow_submission_rejected(): |
| 327 | + client = IndicoClient() |
| 328 | + wfs = client.call(ListWorkflows(dataset_ids=[org_annotate_dataset.id])) |
| 329 | + wf = max(wfs, key=lambda w: w.id) |
| 330 | + wf = client.call( |
| 331 | + UpdateWorkflowSettings(wf, enable_review=True, enable_auto_review=True) |
| 332 | + ) |
| 333 | + assert wf.review_enabled and wf.auto_review_enabled |
| 334 | + |
| 335 | + _file = str(Path(__file__).parents[1]) + "/data/org-sample.pdf" |
| 336 | + |
| 337 | + sub_ids = client.call(WorkflowSubmission(workflow_id=wf.id, files=[_file])) |
| 338 | + subs = client.call(WaitForSubmissions(sub_ids, timeout=120)) |
| 339 | + sub = subs[0] |
| 340 | + assert sub.status == "PENDING_AUTO_REVIEW" |
| 341 | + job = client.call( |
| 342 | + SubmitReview(sub.id, rejected=True) |
| 343 | + ) |
| 344 | + job = client.call(JobStatus(job.id)) |
| 345 | + submissions = client.call( |
| 346 | + ListSubmissions(filters=SubmissionFilter(reviews=SubmissionReviewFilter(rejected=True))) |
| 347 | + ) |
| 348 | + assert sub_ids[0] in [s.id for s in submissions] |
| 349 | + |
| 350 | + |
326 | 351 | def _new_dataset_for_updating(client): |
327 | 352 | # new dataset |
328 | 353 | airline_csv = str(Path(__file__).parents[1]) + "/data/AirlineComplaints.csv" |
|
0 commit comments