dump_to_path.py

importos

fromdataflowsimportFlow, dump_to_path
fromdatapackage_pipelines.wrapperimportingest
fromdatapackage_pipelines.utilities.flow_utilsimportspew_flow

fromdatapackage_pipelines.utilities.stat_utilsimportSTATS_DPP_KEY, STATS_OUT_DP_URL_KEY


defflow(parameters: dict, stats: dict):
out_path=parameters.pop('out-path', '.')
stats.setdefault(STATS_DPP_KEY, {})[STATS_OUT_DP_URL_KEY] =os.path.join(out_path, 'datapackage.json')
returnFlow(
dump_to_path(
out_path,
**parameters
 )
 )


if__name__=='__main__':
withingest() asctx:
spew_flow(flow(ctx.parameters, ctx.stats), ctx)