(self, errors)
| 776 | self.assertEqual(task_ex_db.status, expected_tk_ex_db_status) |
| 777 | |
| 778 | def sort_workflow_errors(self, errors): |
| 779 | return sorted(errors, key=lambda x: x.get("task_id", None)) |
| 780 | |
| 781 | def assert_task_not_started(self, task_id, route): |
| 782 | task_ex_dbs = wf_db_access.TaskExecution.query( |