def verify_controller_task(self, task, **kwargs):
    self.assertEqual("POST", task["method"])

    request = mock_webapp.MockRequest()
    request.body = base64.b64decode(task["body"])
    request.headers = dict(task["headers"])

    payload = model.HugeTask.decode_payload(request)
    mapreduce_spec = model.MapreduceSpec.from_json_str(
        payload["mapreduce_spec"])
    self.verify_mapreduce_spec(mapreduce_spec, **kwargs)
    self.assertEqual(
        "/mapreduce/controller_callback/" + mapreduce_spec.mapreduce_id,
        task["url"])
Checks that all update status task properties have expected values.
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/handlers_test.py/MapreduceHandlerTestBase.verify_controller_task