Skip to content

Commit

Permalink
propagate should be enabled by default
Browse files Browse the repository at this point in the history
  • Loading branch information
ask committed Aug 16, 2011
1 parent 63b1504 commit 6ec2d6e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions cl/results.py
Expand Up @@ -26,7 +26,7 @@ def _first(self, replies):
def get(self, **kwargs):
return self._first(self.gather(**dict(kwargs, limit=1)))

def gather(self, propagate=False, **kwargs):
def gather(self, propagate=True, **kwargs):
connection = self.actor.connection
gather = self._gather
with producers[connection].acquire(block=True) as producer:
Expand All @@ -35,11 +35,11 @@ def gather(self, propagate=False, **kwargs):
yield r

def _gather(self, *args, **kwargs):
propagate=kwargs.pop("propagate", False)
propagate=kwargs.pop("propagate", True)
return (self.to_python(reply, propagate=propagate)
for reply in self.actor._collect_replies(*args, **kwargs))

def to_python(self, reply, propagate=False):
def to_python(self, reply, propagate=True):
try:
return reply["ok"]
except KeyError:
Expand Down

0 comments on commit 6ec2d6e

Please sign in to comment.