def set_close_callback(self, callback):
        self._close_callback = stack_context.wrap(callback)
Tests that individual shard failure affects the job outcome.
dataset/ETHPy150Open D-L/SimpleBookMarks/src/tornado/iostream.py/BaseIOStream.set_close_callback--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/handlers_test.py/ControllerCallbackHandlerTest.testShardFailureAllDone