def testSliceRecoveryNotCalledWithOutputWriter2(self):
    self.init(output_writer_spec=__name__ + ".TestOutputWriter")

    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)
    self.assertFalse("recover" in TestOutputWriter.events)
Test when the slice isn't a retry.
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/handlers_test.py/MapperWorkerCallbackHandlerTest.testSliceRecoveryNotCalledWithOutputWriter2