135 return self.cw_for_source[0] |
135 return self.cw_for_source[0] |
136 |
136 |
137 |
137 |
138 class CWDataImport(AnyEntity): |
138 class CWDataImport(AnyEntity): |
139 __regid__ = 'CWDataImport' |
139 __regid__ = 'CWDataImport' |
|
140 repo_source = _logs = None # please pylint |
140 |
141 |
141 def __init__(self, *args, **kwargs): |
142 def init(self): |
142 super(CWDataImport, self).__init__(*args, **kwargs) |
|
143 self._logs = [] |
143 self._logs = [] |
|
144 self.repo_source = self.cwsource.repo_source |
144 |
145 |
145 def dc_title(self): |
146 def dc_title(self): |
146 return '%s [%s]' % (self.printable_value('start_timestamp'), |
147 return '%s [%s]' % (self.printable_value('start_timestamp'), |
147 self.printable_value('status')) |
148 self.printable_value('status')) |
148 |
149 |
150 def cwsource(self): |
151 def cwsource(self): |
151 return self.cw_import_of[0] |
152 return self.cw_import_of[0] |
152 |
153 |
153 def record_debug(self, msg, path=None, line=None): |
154 def record_debug(self, msg, path=None, line=None): |
154 self._log(logging.DEBUG, msg, path, line) |
155 self._log(logging.DEBUG, msg, path, line) |
155 self.debug(msg) |
156 self.repo_source.debug(msg) |
156 |
157 |
157 def record_info(self, msg, path=None, line=None): |
158 def record_info(self, msg, path=None, line=None): |
158 self._log(logging.INFO, msg, path, line) |
159 self._log(logging.INFO, msg, path, line) |
159 self.info(msg) |
160 self.repo_source.info(msg) |
160 |
161 |
161 def record_warning(self, msg, path=None, line=None): |
162 def record_warning(self, msg, path=None, line=None): |
162 self._log(logging.WARNING, msg, path, line) |
163 self._log(logging.WARNING, msg, path, line) |
163 self.warning(msg) |
164 self.repo_source.warning(msg) |
164 |
165 |
165 def record_error(self, msg, path=None, line=None): |
166 def record_error(self, msg, path=None, line=None): |
166 self._status = u'failed' |
167 self._status = u'failed' |
167 self._log(logging.ERROR, msg, path, line) |
168 self._log(logging.ERROR, msg, path, line) |
168 self.error(msg) |
169 self.repo_source.error(msg) |
169 |
170 |
170 def record_fatal(self, msg, path=None, line=None): |
171 def record_fatal(self, msg, path=None, line=None): |
171 self._status = u'failed' |
172 self._status = u'failed' |
172 self._log(logging.FATAL, msg, path, line) |
173 self._log(logging.FATAL, msg, path, line) |
173 self.fatal(msg) |
174 self.repo_source.fatal(msg) |
174 |
175 |
175 def _log(self, severity, msg, path=None, line=None): |
176 def _log(self, severity, msg, path=None, line=None): |
176 encodedmsg = u'%s\t%s\t%s\t%s<br/>' % (severity, path or u'', |
177 encodedmsg = u'%s\t%s\t%s\t%s<br/>' % (severity, path or u'', |
177 line or u'', xml_escape(msg)) |
178 line or u'', xml_escape(msg)) |
178 self._logs.append(encodedmsg) |
179 self._logs.append(encodedmsg) |