Show More
@@ -164,7 +164,14 b' def task_retry_signal(' | |||||
164 | @signals.task_failure.connect |
|
164 | @signals.task_failure.connect | |
165 | def task_failure_signal( |
|
165 | def task_failure_signal( | |
166 | task_id, exception, args, kwargs, traceback, einfo, **kargs): |
|
166 | task_id, exception, args, kwargs, traceback, einfo, **kargs): | |
|
167 | from rhodecode.lib.exc_tracking import store_exception | |||
|
168 | ||||
167 | meta.Session.remove() |
|
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 | closer = celery_app.conf['PYRAMID_CLOSER'] |
|
175 | closer = celery_app.conf['PYRAMID_CLOSER'] | |
169 | if closer: |
|
176 | if closer: | |
170 | closer() |
|
177 | closer() |
General Comments 0
You need to be logged in to leave comments.
Login now