(self, task_id, route)
| 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( |
| 783 | task_id=task_id, task_route=route |
| 784 | ) |
| 785 | self.assertEqual(len(task_ex_dbs), 0) |
| 786 | |
| 787 | def assert_task_running(self, task_id, route): |
| 788 | task_ex_db = self.get_task_ex(task_id, route) |