sort.py

fromdataflowsimportFlow, sort_rows
fromdatapackage_pipelines.wrapperimportingest
fromdatapackage_pipelines.utilities.flow_utilsimportspew_flow, load_lazy_json


defflow(parameters):
returnFlow(
load_lazy_json(parameters.get('resources')),
sort_rows(
parameters['sort-by'],
resources=parameters.get('resources'),
reverse=parameters.get('reverse')
 )
 )


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