mgr/orchestrator: Raise more expressive Error, if completion already finished

Eases debugging of tracebacks.

Signed-off-by: Sebastian Wagner <sebastian.wagner@suse.com>

diff --git a/src/pybind/mgr/orchestrator.py b/src/pybind/mgr/orchestrator.py
index 27d3b8f3d35bf831d00f1ae179e68a702cafe25b..ab61c4e297e0ac9976ee7219959579127126d151 100644 (file)
--- a/src/pybind/mgr/orchestrator.py
+++ b/src/pybind/mgr/orchestrator.py
@@ -318,6 +318,9 @@ class _Promise(object):
         Sets the whole completion to be faild with this exception and end the
         evaluation.
         """
+        if self._state == self.FINISHED:
+            raise ValueError(
+                'Invalid State: called fail, but Completion is already finished: {}'.format(str(e)))
         assert self._state in (self.INITIALIZED, self.RUNNING)
         logger.exception('_Promise failed')
         self._exception = e

diff --git a/src/pybind/mgr/tests/test_orchestrator.py b/src/pybind/mgr/tests/test_orchestrator.py
index 584c407cb4cfc964db8f763aedaea63dada94d24..4dd9db76cd9813081fc32c364507c46c56dd0726 100644 (file)
--- a/src/pybind/mgr/tests/test_orchestrator.py
+++ b/src/pybind/mgr/tests/test_orchestrator.py
@@ -228,6 +228,11 @@ def test_fail():
     c._first_promise.fail(KeyError())
     assert isinstance(c.exception, KeyError)
 
+    with pytest.raises(ValueError,
+                  match='Invalid State: called fail, but Completion is already finished: {}'.format(
+                      str(ZeroDivisionError()))):
+        c._first_promise.fail(ZeroDivisionError())
+
 
 def test_pretty_print():
     mgr = mock.MagicMock()