Show More
@@ -64,7 +64,7 b' class HooksCeleryClient:' | |||||
64 |
|
64 | |||
65 | def __call__(self, method, extras): |
|
65 | def __call__(self, method, extras): | |
66 | # NOTE: exception handling for those tasks executed is in |
|
66 | # NOTE: exception handling for those tasks executed is in | |
67 |
# @ad |
|
67 | # @adopt_for_celery decorator | |
68 | # also see: _maybe_handle_exception which is handling exceptions |
|
68 | # also see: _maybe_handle_exception which is handling exceptions | |
69 |
|
69 | |||
70 | inquired_task = self.celery_app.signature(f'rhodecode.lib.celerylib.tasks.{method}') |
|
70 | inquired_task = self.celery_app.signature(f'rhodecode.lib.celerylib.tasks.{method}') | |
@@ -123,7 +123,7 b' class SvnMessageWriter(RemoteMessageWrit' | |||||
123 | def _maybe_handle_exception(writer, result): |
|
123 | def _maybe_handle_exception(writer, result): | |
124 | """ |
|
124 | """ | |
125 | adopt_for_celery defines the exception/exception_traceback |
|
125 | adopt_for_celery defines the exception/exception_traceback | |
126 | Ths result is a direct output from a celery task |
|
126 | This result is a direct output from a celery task | |
127 | """ |
|
127 | """ | |
128 |
|
128 | |||
129 | exception_class = result.get('exception') |
|
129 | exception_class = result.get('exception') |
General Comments 0
You need to be logged in to leave comments.
Login now