# HG changeset patch # User Ralph Meijer # Date 1100725203 0 # Node ID 878a5b7697f25f40308a068477f09d74aa65dc0c # Parent 47ee5369c4102ae2e156b4f0487d4389bd9d35b7 Consume errors in DeferredLists. diff -r 47ee5369c410 -r 878a5b7697f2 idavoll/backend.py --- a/idavoll/backend.py Wed Nov 17 20:43:45 2004 +0000 +++ b/idavoll/backend.py Wed Nov 17 21:00:03 2004 +0000 @@ -198,7 +198,7 @@ def publish(self, node_id, items, requestor): d1 = self.parent.storage.get_node_configuration(node_id) d2 = self.parent.storage.get_affiliation(node_id, requestor) - d = defer.DeferredList([d1, d2], fireOnOneErrback=1) + d = defer.DeferredList([d1, d2], fireOnOneErrback=1, consumeErrors=1) d.addErrback(lambda x: x.value[0]) d.addCallback(self._do_publish, node_id, items, requestor) return d @@ -270,7 +270,7 @@ d1 = self.parent.storage.get_node_configuration(node_id) d2 = self.parent.storage.get_affiliation(node_id, subscriber) - d = defer.DeferredList([d1, d2], fireOnOneErrback=1) + d = defer.DeferredList([d1, d2], fireOnOneErrback=1, consumeErrors=1) d.addErrback(lambda x: x.value[0]) d.addCallback(self._do_subscribe, node_id, subscriber) return d @@ -326,7 +326,7 @@ def get_affiliations(self, entity): d1 = self.parent.storage.get_affiliations(entity) d2 = self.parent.storage.get_subscriptions(entity) - d = defer.DeferredList([d1, d2], fireOnOneErrback=1) + d = defer.DeferredList([d1, d2], fireOnOneErrback=1, consumeErrors=1) d.addErrback(lambda x: x.value[0]) d.addCallback(self._affiliations_result, entity) return d diff -r 47ee5369c410 -r 878a5b7697f2 idavoll/idavoll.py --- a/idavoll/idavoll.py Wed Nov 17 20:43:45 2004 +0000 +++ b/idavoll/idavoll.py Wed Nov 17 21:00:03 2004 +0000 @@ -52,7 +52,7 @@ if components.implements(c, component.IService): if hasattr(c, "get_disco_info"): dl.append(c.get_disco_info(node)) - d = defer.DeferredList(dl, fireOnOneErrback=1) + d = defer.DeferredList(dl, fireOnOneErrback=1, consumeErrors=1) d.addCallback(self._disco_info_results, iq, node) d.addErrback(self._error, iq) d.addCallback(self.send) @@ -84,7 +84,7 @@ if components.implements(c, component.IService): if hasattr(c, "get_disco_items"): dl.append(c.get_disco_items(node)) - d = defer.DeferredList(dl, fireOnOneErrback=1) + d = defer.DeferredList(dl, fireOnOneErrback=1, consumeErrors=1) d.addCallback(self._disco_items_result, iq, node) d.addErrback(self._error, iq) d.addCallback(self.send)