def n1qlQueryAll(self, *args, **kwargs):
        if not self.connected:
            cb = lambda x: self.n1qlQueryAll(*args, **kwargs)
            return self.connect().addCallback(cb)

        kwargs['itercls'] = BatchedN1QLRequest
        o = super(RawBucket, self).n1ql_query(*args, **kwargs)
        o.start()
        return o._getDeferred()
Terminate all nodes
dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py/RawBucket.n1qlQueryAll--crossover with--dataset/ETHPy150Open tomcz/aws_py/fabfile.py/stop_all