def testUserAbort(self):
    # Be sure to have an output writer for the abort step so we can confirm
    # that the finalize() method is never called.
    self.init(__name__ + ".test_handler_yield_keys",
              output_writer_spec=__name__ + ".UnfinalizableTestOutputWriter")

    model.MapreduceControl.abort(self.mapreduce_id, force_writes=True)
    self._handle_request(expect_finalize=False)
    self.verify_shard_state(
        model.ShardState.get_by_shard_id(self.shard_id),
        active=False,
        result_status=model.ShardState.RESULT_ABORTED)
L{Meter.get_event_type}
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/handlers_test.py/MapperWorkerCallbackHandlerTest.testUserAbort--crossover with--dataset/ETHPy150Open dreid/yunomi/yunomi/core/timer.py/Timer.get_event_type