-
Notifications
You must be signed in to change notification settings - Fork 276
/
exceptions.py
239 lines (156 loc) · 6.52 KB
/
exceptions.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
# Copyright 2013: Mirantis Inc.
# All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
from rally.common.plugin import discover
_exception_map = None
class RallyException(Exception):
"""Base Rally Exception
To correctly use this class, inherit from it and define
a "msg_fmt" property. That msg_fmt will get printf'd
with the keyword arguments provided to the constructor.
"""
msg_fmt = "%(message)s"
error_code = 100
def __init__(self, message=None, **kwargs):
self.kwargs = kwargs
if "%(message)s" in self.msg_fmt:
kwargs.update({"message": message})
super(RallyException, self).__init__(self.msg_fmt % kwargs)
def format_message(self):
return str(self)
def find_exception(response):
"""Discover a proper exception class based on response object."""
global _exception_map
if _exception_map is None:
_exception_map = dict(
(e.error_code, e) for e in discover.itersubclasses(RallyException))
exc_class = _exception_map.get(response.status_code, RallyException)
error_data = response.json()["error"]
if error_data["args"]:
return exc_class(error_data["args"])
return exc_class(error_data["msg"])
def make_exception(exc):
"""Check a class of exception and convert it to rally-like if needed."""
if isinstance(exc, RallyException):
return exc
return RallyException(str(exc))
class ValidationError(RallyException):
error_code = 110
msg_fmt = "Validation error: %(message)s"
class InvalidArgumentsException(RallyException):
error_code = 111
msg_fmt = "Invalid arguments: '%(message)s'"
class InvalidConfigException(RallyException):
error_code = 112
msg_fmt = "This config has invalid schema: `%(message)s`"
class InvalidTaskException(InvalidConfigException):
error_code = 113
msg_fmt = "Task config is invalid: `%(message)s`"
class InvalidTaskConfig(InvalidTaskException):
error_code = 114
msg_fmt = ("Input task is invalid!\n\n"
"Subtask %(name)s[%(pos)s] has wrong configuration"
"\nSubtask configuration:\n%(config)s\n"
"\nReason(s):\n %(reason)s")
class InvalidScenarioArgument(RallyException):
error_code = 115
msg_fmt = "Invalid scenario argument: '%(message)s'"
class InvalidConnectionString(RallyException):
error_code = 116
msg_fmt = "Invalid connection string: %(message)s."
class DBException(RallyException):
error_code = 200
msg_fmt = "DB Exception: '%(message)s'"
class DBMigrationError(DBException):
error_code = 201
msg_fmt = "DB Migration Error: '%(message)s'"
class DBConflict(RallyException):
error_code = 202
msg_fmt = "DB Conflict. %(message)s"
class DBRecordNotFound(RallyException):
error_code = 203
msg_fmt = "Record for %(criteria)s not found in table %(table)s"
class DBRecordExists(DBException):
error_code = 204
msg_fmt = "Record with %(field)s = %(value)s already exists in %(table)s"
class DowngradeNotSupported(RallyException):
error_code = 205
msg_fmt = "Database schema downgrade is not supported."
class NotFoundException(RallyException):
error_code = 210
msg_fmt = "The resource can not be found: %(message)s"
class PluginNotFound(NotFoundException):
error_code = 211
msg_fmt = "There is no%(base)s plugin `%(name)s` in %(platform)s " \
"platform."
class PluginWithSuchNameExists(RallyException):
error_code = 212
msg_fmt = (
"Plugin with such name: %(name)s already exists in %(platform)s "
"platform. It's module allocates at %(existing_path)s. You are trying "
"to add plugin whose module allocates at %(new_path)s.")
class MultiplePluginsFound(RallyException):
error_code = 213
msg_fmt = ("Multiple plugins found: %(plugins)s for name %(name)s. "
"Use full name with platform to fix issue.")
class GetResourceFailure(RallyException):
error_code = 214
msg_fmt = "Failed to get the resource %(resource)s: %(err)s"
class GetResourceNotFound(GetResourceFailure):
error_code = 215
msg_fmt = "Resource %(resource)s is not found."
class GetResourceErrorStatus(GetResourceFailure):
error_code = 216
msg_fmt = "Resource %(resource)s has %(status)s status.\n Fault: %(fault)s"
class AuthenticationFailed(InvalidArgumentsException):
error_code = 220
msg_fmt = ("Failed to authenticate to %(url)s for user '%(username)s'"
" in project '%(project)s': %(etype)s: %(error)s")
class InvalidAdminException(InvalidArgumentsException):
error_code = 221
msg_fmt = "user '%(username)s' doesn't have 'admin' role"
class DeploymentNotFinishedStatus(RallyException):
error_code = 222
msg_fmt = "Deployment '%(name)s' (UUID=%(uuid)s) is '%(status)s'."
class ContextSetupFailure(RallyException):
error_code = 223
msg_fmt = "Unable to setup context '%(ctx_name)s': '%(msg)s'"
class ManagerException(RallyException):
error_code = 230
msg_fmt = "Internal error: %(message)s"
class ManagerInvalidSpec(ManagerException):
error_code = 231
msg_fmt = "%(mgr)s manager got invalid spec: \n%(errors)s"
class ManagerInvalidState(ManagerException):
error_code = 232
msg_fmt = ("%(mgr)s manager in invalid state "
"expected `%(expected)s' actual `%(actual)s' ")
class TimeoutException(RallyException):
error_code = 240
msg_fmt = ("Rally tired waiting %(timeout).2f seconds for "
"%(resource_type)s %(resource_name)s:%(resource_id)s to "
"become %(desired_status)s current status %(resource_status)s")
class ThreadTimeoutException(RallyException):
error_code = 241
msg_fmt = "Iteration interrupted due to timeout."
class SSHTimeout(RallyException):
error_code = 242
pass
class SSHError(RallyException):
error_code = 243
pass
class RallyAssertionError(RallyException):
msg_fmt = "Assertion error: %(message)s"
class ScriptError(RallyException):
msg_fmt = "Script execution failed: %(message)s"