Add the exception's message to the traceback
This commit is contained in:
parent
6007789480
commit
7ef3be5842
1 changed files with 3 additions and 2 deletions
|
@ -44,8 +44,9 @@ def _run(get_producer, queues, chunk_size, args):
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
data = producer(chunk_size) or None
|
data = producer(chunk_size) or None
|
||||||
except Exception:
|
except Exception as ex:
|
||||||
data = Exception("".join(traceback.format_exception(*sys.exc_info())))
|
message = '%s\n%s' % (ex.message, "".join(traceback.format_exception(*sys.exc_info())))
|
||||||
|
data = Exception(message)
|
||||||
|
|
||||||
for queue in queues:
|
for queue in queues:
|
||||||
try:
|
try:
|
||||||
|
|
Reference in a new issue