def create_mapreduce_state(self, output_params=None):
    all_params = {self.WRITER_CLS.BUCKET_NAME_PARAM: self.BUCKET_NAME}
    all_params.update(output_params or {})
    return super(GCSRecordOutputWriterTestBase, self).create_mapreduce_state(
        all_params)
Create a model.MapreduceState including MapreduceSpec and MapperSpec.
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/output_writers_test.py/GCSRecordOutputWriterTestBase.create_mapreduce_state