diff --git a/pikatasks/__init__.py b/pikatasks/__init__.py index 0e9e13816767943bcd361a12034a06c4e6c4d1df..9484f389c2a14a62f212c90d1f322be724fcaa40 100644 --- a/pikatasks/__init__.py +++ b/pikatasks/__init__.py @@ -49,6 +49,7 @@ def run(_task_name, **kwargs): properties=pika.BasicProperties() ) except Exception as e: + logger.debug(traceback.format_exc()) logger.error("{}: {}".format(e.__class__.__name__, str(e))) raise RPCMessageQueueError(e) @@ -109,7 +110,7 @@ def rpc(_task_name, **kwargs): channel.start_consuming() channel.close() # after stopped consuming by either of the callbacks except Exception as e: - logger.error(traceback.format_exc()) + logger.debug(traceback.format_exc()) logger.error("{}: {}".format(e.__class__.__name__, str(e))) exception = RPCMessageQueueError(e) # done, return the result or indicate a problem