Safely send back the given result or exception
(result_queue, work_id, result=None, exception=None,
exit_pid=None)
| 204 | |
| 205 | |
| 206 | def _sendback_result(result_queue, work_id, result=None, exception=None, |
| 207 | exit_pid=None): |
| 208 | """Safely send back the given result or exception""" |
| 209 | try: |
| 210 | result_queue.put(_ResultItem(work_id, result=result, |
| 211 | exception=exception, exit_pid=exit_pid)) |
| 212 | except BaseException as e: |
| 213 | exc = _ExceptionWithTraceback(e, e.__traceback__) |
| 214 | result_queue.put(_ResultItem(work_id, exception=exc, |
| 215 | exit_pid=exit_pid)) |
| 216 | |
| 217 | |
| 218 | def _process_worker(call_queue, result_queue, initializer, initargs, max_tasks=None): |
no test coverage detected
searching dependent graphs…