try:
c.execute()
except Exception as e:
- self.log.exception("Completion {0} threw an exception:".format(
- c.message
- ))
- c.error = e
+ if not isinstance(e, orchestrator.OrchestratorError):
+ self.log.exception("Completion {0} threw an exception:".format(
+ c.message
+ ))
+ c.exception = e
c._complete = True
if not c.is_complete:
@deferred_read
def describe_service(self, service_type=None, service_id=None, node_name=None):
- assert service_type in ("mds", "osd", "mgr", "mon", "nfs", None), service_type + " unsupported"
+ if service_type not in ("mds", "osd", "mgr", "mon", "nfs", None):
+ raise orchestrator.OrchestratorValidationError(service_type + " unsupported")
pods = self.rook_cluster.describe_pods(service_type, service_id, node_name)