def ModifyTaskLease_Rpc(self, request, response):
    self._CheckQueueForRpc(request.queue_name())
    self._queues[request.queue_name()].ModifyTaskLease_Rpc(request, response)
Flush output and process input while waiting for any of the given
dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/taskqueue/taskqueue_stub.py/_Group.ModifyTaskLease_Rpc--crossover with--dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingConnection._flush_output