From 467d99f6984f967679cb05b97d656ad94f12220b Mon Sep 17 00:00:00 2001 From: mike cullerton Date: Tue, 25 Jan 2022 12:19:32 -0500 Subject: [PATCH] Test for processing erroring workflows. This only tests that we have good information in the message, not whether the message was sent. --- tests/test_process_erroring_workflows.py | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 tests/test_process_erroring_workflows.py diff --git a/tests/test_process_erroring_workflows.py b/tests/test_process_erroring_workflows.py new file mode 100644 index 00000000..8281eaa0 --- /dev/null +++ b/tests/test_process_erroring_workflows.py @@ -0,0 +1,20 @@ +from tests.base_test import BaseTest + +from crc import session +from crc.models.workflow import WorkflowStatus +from crc.services.workflow_service import WorkflowService + + +class TestErrorWorkflows(BaseTest): + + def test_error_workflows(self): + + workflow_1 = self.create_workflow('random_fact') + workflow_1.status = WorkflowStatus.erroring + workflow_2 = self.create_workflow('random_fact') + workflow_2.status = WorkflowStatus.erroring + session.commit() + message = WorkflowService().process_erroring_workflows() + self.assertIn('There are 2 workflows in an error state.', message) + self.assertIn(f'workflow/{workflow_1.id}', message) + self.assertIn(f'workflow/{workflow_2.id}', message)