Show More
@@ -164,7 +164,14 b' def task_retry_signal(' | |||
|
164 | 164 | @signals.task_failure.connect |
|
165 | 165 | def task_failure_signal( |
|
166 | 166 | task_id, exception, args, kwargs, traceback, einfo, **kargs): |
|
167 | from rhodecode.lib.exc_tracking import store_exception | |
|
168 | ||
|
167 | 169 | meta.Session.remove() |
|
170 | ||
|
171 | # simulate sys.exc_info() | |
|
172 | exc_info = (einfo.type, einfo.exception, einfo.tb) | |
|
173 | store_exception(id(exc_info), exc_info, prefix='celery_rhodecode') | |
|
174 | ||
|
168 | 175 | closer = celery_app.conf['PYRAMID_CLOSER'] |
|
169 | 176 | if closer: |
|
170 | 177 | closer() |
General Comments 0
You need to be logged in to leave comments.
Login now