def testDatastoreExceptionInHandler(self):
    self.init(__name__ + ".test_handler_yield_keys")
    TestEntity().put()
    original_method = datastore.PutAsync
    datastore.PutAsync = mock.MagicMock(side_effect=datastore_errors.Timeout())

    # Tests that handler doesn't abort task for datastore errors.
    # Unfornately they still increase TaskExecutionCount.
    for _ in range(parameters.config.TASK_MAX_DATA_PROCESSING_ATTEMPTS):
      self.assertRaises(datastore_errors.Timeout, self.handler.post)
    self.verify_shard_state(
        model.ShardState.get_by_shard_id(self.shard_id),
        active=True,
        processed=0)

    datastore.PutAsync = original_method
    self._handle_request()

    self.verify_shard_state(
        model.ShardState.get_by_shard_id(self.shard_id),
        active=False, input_finished=True,
        result_status=model.ShardState.RESULT_SUCCESS,
        processed=1)
return True if the query starts with any of the given words
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/handlers_test.py/MapperWorkerCallbackHandlerTest.testDatastoreExceptionInHandler--crossover with--dataset/ETHPy150Open frappe/frappe/frappe/utils/bot.py/BotParser.startswith