@_WithLock
  def QueryTasks_Rpc(self, request, response):

    assert not request.has_start_tag()

    if request.has_start_eta_usec():
      tasks = self._LookupNoAcquireLock(request.max_rows(),
                                        name=request.start_task_name(),
                                        eta=request.start_eta_usec())
    else:
      tasks = self._LookupNoAcquireLock(request.max_rows(),
                                        name=request.start_task_name())
    for task in tasks:
      response.add_task().MergeFrom(task)
Verify that content type can be set explicitly and used.
dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/taskqueue/taskqueue_stub.py/_Queue.QueryTasks_Rpc--crossover with--dataset/ETHPy150Open viewfinderco/viewfinder/backend/www/test/new_client_log_url_test.py/NewClientLogUrlTestCase.testContentType