release: 0.4.2

bonobo/_version.py

@@ -1 +1 @@
-__version__ = '0.4.1'
+__version__ = '0.4.2'

bonobo/strategies/executor.py

@@ -28,6 +28,7 @@ class ExecutorStrategy(Strategy):
         futures = []
 
         for plugin_context in context.plugins:
+
             def _runner(plugin_context=plugin_context):
                 with plugin_context:
                     try:
@@ -38,6 +39,7 @@ class ExecutorStrategy(Strategy):
             futures.append(executor.submit(_runner))
 
         for node_context in context.nodes:
+
             def _runner(node_context=node_context):
                 try:
                     node_context.start()

docs/changelog.rst

@@ -1,6 +1,23 @@
 Changelog
 =========
 
+v.0.4.2 - 18 june 2017
+::::::::::::::::::::::
+
+* [config] Implements a "requires()" service injection decorator for functions (api may change).
+* [core] Execution contexts are now context managers.
+* [fs] adds a defaut to current working directory in open_fs(...).
+* [logging] Adds logging alias for easier imports.
+* [stdlib] Fix I/O related nodes (especially json), there were bad bugs with ioformat.
+
+Dependency updates
+------------------
+
+* Update bonobo-docker from 0.2.6 to 0.2.8
+* Update dependencies.
+* Update fs from 2.0.3 to 2.0.4
+* Update requests from 2.17.3 to 2.18.1
+
 v.0.4.0 - 10 june 2017
 ::::::::::::::::::::::
 

tests/io/test_csv.py

@@ -26,7 +26,7 @@ def test_write_csv_to_file_arg0(tmpdir):
 
 @pytest.mark.parametrize('add_kwargs', ({}, {
     'ioformat': settings.IOFORMAT_KWARGS,
-},))
+}, ))
 def test_write_csv_to_file_kwargs(tmpdir, add_kwargs):
     fs, filename, services = csv_tester.get_services_for_writer(tmpdir)
 
@@ -46,8 +46,8 @@ def test_read_csv_from_file_arg0(tmpdir):
     fs, filename, services = csv_tester.get_services_for_reader(tmpdir)
 
     with CapturingNodeExecutionContext(
-            CsvReader(path=filename, delimiter=',', ioformat=settings.IOFORMAT_ARG0),
+        CsvReader(path=filename, delimiter=',', ioformat=settings.IOFORMAT_ARG0),
-            services=services,
+        services=services,
     ) as context:
         context.write(BEGIN, Bag(), END)
         context.step()
@@ -75,8 +75,8 @@ def test_read_csv_from_file_kwargs(tmpdir):
     fs, filename, services = csv_tester.get_services_for_reader(tmpdir)
 
     with CapturingNodeExecutionContext(
-            CsvReader(path=filename, delimiter=','),
+        CsvReader(path=filename, delimiter=','),
-            services=services,
+        services=services,
     ) as context:
         context.write(BEGIN, Bag(), END)
         context.step()