

def start(self, **kwargs):
    if ('base_path' not in kwargs):
        kwargs['base_path'] = parameters._DEFAULT_PIPELINE_BASE_PATH
    return pipeline.Pipeline.start(self, **kwargs)

dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/src/mapreduce/pipeline_base.py PipelineBase.start/original