Mercurial > libervia-pubsub
diff idavoll/backend.py @ 92:878a5b7697f2
Consume errors in DeferredLists.
| author | Ralph Meijer <ralphm@ik.nu> |
|---|---|
| date | Wed, 17 Nov 2004 21:00:03 +0000 |
| parents | 59378610b16e |
| children | 3ad74552bbc7 |
line wrap: on
line diff
--- 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