mock worflow.run to throw exception

python/tests/res/job_queue/test_workflow_runner.py

@@ -5,6 +5,7 @@
 from ecl.util.test import TestAreaContext
 from res.util.substitution_list import SubstitutionList
 from .workflow_common import WorkflowCommon
+from unittest import mock
 
 
 class WorkflowRunnerTest(ResTest):
@@ -96,6 +97,7 @@ def test_workflow_thread_cancel_external(self):
             self.assertFileDoesNotExist("wait_cancelled_2")
             self.assertFileDoesNotExist("wait_finished_2")
 
+
     def test_workflow_failed_job(self):
         with TestAreaContext("python/job_queue/workflow_runner_fails") as work_area:
             WorkflowCommon.createExternalDumpJob()
@@ -108,16 +110,10 @@ def test_workflow_failed_job(self):
             workflow_runner = WorkflowRunner(workflow, ert=None, context=SubstitutionList())
 
             self.assertFalse(workflow_runner.isRunning())
-
-            workflow_runner.run()
-            workflow_runner.wait()
-            print('DBG errorlist: ', workflow_runner.workflowReport())
-            self.assertNotEqual(workflow_runner.runner_thread._exception, None)
-
-
-
-
-
+            with mock.patch.object(Workflow, 'run', side_effect=Exception('mocked workflow error')):
+                workflow_runner.run()
+                workflow_runner.wait()
+                self.assertNotEqual(workflow_runner.runner_thread._exception, None)
 
     def test_workflow_success(self):
         with TestAreaContext("python/job_queue/workflow_runner_fast") as work_area: