def flood_to(self, subscriptions): jobs = [ gevent.spawn(self._pull_from, subscription) for subscription in subscriptions ] gevent.wait(jobs)