diff --git a/pikatasks/__init__.py b/pikatasks/__init__.py index ab74302f61baebf6c7c4952d62ed0228fc327723..f2c0112ca976cc14e2965128dfd1923042f76f2f 100644 --- a/pikatasks/__init__.py +++ b/pikatasks/__init__.py @@ -104,6 +104,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.error("{}: {}".format(e.__class__.__name__, str(e))) exception = RPCMessageQueueError(e) # done, return the result or indicate a problem