WIP: +Solution class to fix multithreading x3TCs FAIL!

Author: ankostis

docs/source/index.rst

@@ -25,7 +25,8 @@ It might be of use in computer vision, machine learning and other data science d
 or become the core of a custom ETL pipelne.
 
 .. toctree::
-   :maxdepth: 2
+   :maxdepth: 3
+   :numbered:
 
    operations
    composition

docs/source/operations.rst

@@ -137,5 +137,11 @@ Modifiers on ``operation`` inputs and outputs
 
 Certain modifiers are available to apply to input or output values in ``needs`` and ``provides``, for example to designate an optional input.  These modifiers are available in the ``graphkit.modifiers`` module:
 
+
+Optionals
+^^^^^^^^^
 .. autoclass:: graphkit.modifiers.optional
+
+Sideffects
+^^^^^^^^^^
 .. autoclass:: graphkit.modifiers.sideffect

docs/source/reference.rst

@@ -2,6 +2,11 @@
 API Reference
 =============
 
+Package: `graphkit`
+===================
+
+.. automodule:: graphkit
+
 Module: `base`
 ==============
 

graphkit/__init__.py

@@ -14,4 +14,4 @@
 
 # For backwards compatibility
 from .base import Operation
-from .network import Network
+from .network import Network, Solution

graphkit/base.py

@@ -291,7 +291,6 @@ def __init__(self, **kwargs):
 
         # set execution mode to single-threaded sequential by default
         self._execution_method = "sequential"
-        self._overwrites_collector = None
 
     def _build_pydot(self, **kws):
         """delegate to network"""
@@ -300,12 +299,7 @@ def _build_pydot(self, **kws):
         return plotter._build_pydot(**kws)
 
     def _compute(self, named_inputs, outputs=None):
-        return self.net.compute(
-            named_inputs,
-            outputs,
-            method=self._execution_method,
-            overwrites_collector=self._overwrites_collector,
-        )
+        return self.net.compute(named_inputs, outputs, method=self._execution_method)
 
     def __call__(self, *args, **kwargs):
         return self._compute(*args, **kwargs)
@@ -328,24 +322,6 @@ def set_execution_method(self, method):
             )
         self._execution_method = method
 
-    def set_overwrites_collector(self, collector):
-        """
-        Asks to put all *overwrites* into the `collector` after computing
-
-        An "overwrites" is intermediate value calculated but NOT stored
-        into the results, becaues it has been given also as an intemediate
-        input value, and the operation that would overwrite it MUST run for
-        its other results.
-
-        :param collector:
-            a mutable dict to be fillwed with named values
-        """
-        if collector is not None and not isinstance(collector, abc.MutableMapping):
-            raise ValueError(
-                "Overwrites collector was not a MutableMapping, but: %r" % collector
-            )
-        self._overwrites_collector = collector
-
     def __getstate__(self):
         state = Operation.__getstate__(self)
         state["net"] = self.__dict__["net"]