1 new commit in galaxy-central:
https://bitbucket.org/galaxy/galaxy-central/commits/98acf7d104af/ Changeset: 98acf7d104af User: jmchilton Date: 2014-06-19 20:11:55 Summary: Another LWR client update - improved exception logging. Affected #: 1 file
diff -r 5111c44e87f5fb22e6340cdbf3104e6aea83d54c -r 98acf7d104afb923cd538a09f49fc58828d17e1c lib/galaxy/jobs/runners/lwr_client/amqp_exchange.py --- a/lib/galaxy/jobs/runners/lwr_client/amqp_exchange.py +++ b/lib/galaxy/jobs/runners/lwr_client/amqp_exchange.py @@ -53,9 +53,13 @@ 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):
Repository URL: https://bitbucket.org/galaxy/galaxy-central/
--
This is a commit notification from bitbucket.org. You are receiving this because you have the service enabled, addressing the recipient of this email.