Method assert_task_running

st2tests/st2tests/base.py:787–791

(self, task_id, route)

        self.assertEqual(len(task_ex_dbs), 0)

    def assert_task_running(self, task_id, route):
        task_ex_db = self.get_task_ex(task_id, route)
        self.assertEqual(task_ex_db.task_id, task_id)
        self.assertEqual(task_ex_db.task_route, route)
        self.assertEqual(task_ex_db.status, wf_statuses.RUNNING)

    def assert_workflow_completed(self, wf_ex_id, status=None):
        wf_ex_db = wf_db_access.WorkflowExecution.get_by_id(wf_ex_id)