opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-10-25 10:24:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

Another LWR client update - improved exception logging.

Browse Source
This commit is contained in:
John Chilton
2014-06-19 13:11:55 -05:00
parent 26d9d39e9d
commit 42fd8abddc
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/galaxy/jobs/runners/lwr_client/amqp_exchange.py
+6 -2
View File
@@ -53,9 +53,13 @@ class LwrExchange(object):
self.__connect_ssl = connect_ssl
self.__exchange = kombu.Exchange(DEFAULT_EXCHANGE_NAME, DEFAULT_EXCHANGE_TYPE)
self.__timeout = timeout
# Be sure to log message publishing failures.
if publish_kwds.get("retry", False):
if "retry_policy" not in publish_kwds:
publish_kwds["retry_policy"] = {}
if "errback" not in publish_kwds["retry_policy"]:
publish_kwds["retry_policy"]["errback"] = self.__publish_errback
self.__publish_kwds = publish_kwds
if "retry_policy" in self.__publish_kwds:
self.__publish_kwds["retry_policy"]["errback"] = self.__publish_errback
@property
def url(self):