Stdout redirect for high-level API as well

frictionlessdata · Oct 18, 2018 · e3f9dbd · e3f9dbd
1 parent 7d6fdc4
commit e3f9dbd
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/datapackage_pipelines/wrapper/wrapper.py b/datapackage_pipelines/wrapper/wrapper.py
@@ -221,13 +221,13 @@ def process(modify_datapackage=None,
     stats = {}
     with ingest(debug=debug) as ctx:
         if modify_datapackage is not None:
-            datapackage = modify_datapackage(ctx.datapackage, ctx.parameters, stats)
+            ctx.datapackage = modify_datapackage(ctx.datapackage, ctx.parameters, stats)
 
         if process_row is not None:
             new_iter = generic_process_resources(ctx.resource_iterator,
                                                  ctx.parameters,
                                                  stats,
                                                  process_row)
-            spew(datapackage, new_iter, stats)
+            spew(ctx.datapackage, new_iter, stats)
         else:
-            spew(datapackage, ctx.resource_iterator, stats)
+            spew(ctx.datapackage, ctx.resource_iterator, stats)