REFACT: Rename module OP-->COMPOSITION

Author: ankostis

docs/source/arch.rst

@@ -36,8 +36,8 @@ Architecture
 
         .. autosummary::
 
-            graphtik.op.FunctionalOperation
-            graphtik.op.NetworkOperation
+            graphtik.composition.FunctionalOperation
+            graphtik.composition.NetworkOperation
             graphtik.network.Network
             graphtik.execution.ExecutionPlan
             graphtik.execution.Solution

docs/source/plotting.rst

@@ -509,7 +509,7 @@ in :term:`parallel`::
    DEBUG    === (3C40) Executing netop(t), in parallel, on inputs[], according to ExecutionPlan(needs=[], provides=['b'], x2 steps: op1, op2)...
    DEBUG    +++ (3C40) Parallel batch['op1'] on solution[].
    DEBUG    +++ (3C40) Executing OpTask(FunctionalOperation|(name='op1', needs=[], provides=[sfx: 'b'], fn{}='<lambda>'), sol_keys=[])...
-   INFO     graphtik.op:op.py:534 Results[sfx: 'b'] contained +1 unknown provides[sfx: 'b']
+   INFO     graphtik.composition:op.py:534 Results[sfx: 'b'] contained +1 unknown provides[sfx: 'b']
    FunctionalOperation|(name='op1', needs=[], provides=[sfx: 'b'], fn{}='<lambda>')
    DEBUG    ... (3C40) op(op1) completed in 1.406ms.
 
@@ -519,7 +519,7 @@ in :term:`parallel`::
    DEBUG    ... cache-hit key: ((), None, None)
    DEBUG    === (8697) Executing netop(t), evicting, on inputs[], according to ExecutionPlan(needs=[], provides=['b'], x3 steps: op1, op2, sfx: 'b')...
    DEBUG    +++ (8697) Executing OpTask(FunctionalOperation(name='op1', needs=[], provides=[sfx: 'b'], fn{}='<lambda>'), sol_keys=[])...
-   INFO     graphtik.op:op.py:534 Results[sfx: 'b'] contained +1 unknown provides[sfx: 'b']
+   INFO     graphtik.composition:op.py:534 Results[sfx: 'b'] contained +1 unknown provides[sfx: 'b']
    FunctionalOperation(name='op1', needs=[], provides=[sfx: 'b'], fn{}='<lambda>')
    DEBUG    ... (8697) op(op1) completed in 0.149ms.
    DEBUG    +++ (8697) Executing OpTask(FunctionalOperation(name='op2', needs=[sfx: 'b'], provides=['b'], fn='<lambda>'), sol_keys=[sfx: 'b'])...

docs/source/reference.rst

@@ -5,7 +5,7 @@ API Reference
 .. autosummary::
 
      graphtik
-     graphtik.op
+     graphtik.composition
      graphtik.modifiers
      graphtik.network
      graphtik.execution
@@ -17,10 +17,10 @@ API Reference
 .. raw:: html
      :file: images/GraphtikModuleDependencies.svg
 
-Module: `op`
-====================
+Module: `composition`
+=====================
 
-.. automodule:: graphtik.op
+.. automodule:: graphtik.composition
      :members:
      :undoc-members:
      :private-members:

graphtik/__init__.py

@@ -48,7 +48,7 @@
     vararg,
     varargs,
 )
-from .op import NULL_OP, operation, compose
+from .composition import NULL_OP, operation, compose
 
 ## SEE ALSO: `.plot.active_plotter_plugged()`, `.plot.set_active_plotter()` &
 #  `.plot.get_active_plotter()` configs, not imported, unless plot is needed..

graphtik/op.py renamed to graphtik/composition.py

@@ -3,9 +3,7 @@
 """
 .. default-role: term
 
-`compose` `operation` & `dependency` into `pipeline`\\s..
-
-and match/zip inputs/outputs during `execution .
+`compose` `operation` & `dependency` into `pipeline`\\s match/zip inputs/outputs during `execution`.
 
 .. default-role:
 """

graphtik/execution.py

@@ -41,7 +41,7 @@
     yield_node_names,
     yield_ops,
 )
-from .op import Operation
+from .composition import Operation
 
 #: If this logger is *eventually* DEBUG-enabled,
 #: the string-representation of network-objects (network, plan, solution)

graphtik/network.py

@@ -24,7 +24,7 @@
 from .base import Items, PlotArgs, Plottable, astuple, jetsam
 from .config import is_debug, is_skip_evictions
 from .modifiers import dep_renamed, is_mapped, is_optional, is_sfx, optional
-from .op import FunctionalOperation, Operation
+from .composition import FunctionalOperation, Operation
 
 NodePredicate = Callable[[Any, Mapping], bool]
 
@@ -639,7 +639,7 @@ def build_network(
         see same-named param in :func:`.compose`
     """
     from boltons.setutils import IndexedSet as iset
-    from .op import NULL_OP, NetworkOperation
+    from .composition import NULL_OP, NetworkOperation
 
     def proc_op(op, parent=None):
         """clone FuncOperation with certain props changed"""

graphtik/plot.py

@@ -52,7 +52,7 @@
     is_reschedule_operations,
 )
 from .modifiers import is_mapped, is_sfx, is_sfxed
-from .op import Operation
+from .composition import Operation
 
 log = logging.getLogger(__name__)
 

test/test_base.py

@@ -8,9 +8,9 @@
 
 import pytest
 
-from graphtik import base, network, op, operation
+from graphtik import base, network, composition, operation
 from graphtik.execution import ExecutionPlan, Solution, _OpTask
-from graphtik.op import NetworkOperation
+from graphtik.composition import NetworkOperation, Operation
 
 
 @pytest.mark.parametrize("locs", [None, (), [], [0], "bad"])
@@ -131,7 +131,7 @@ def outer():
     assert excinfo.value.jetsam == {"fn": "inner", "a": 1, "b": 2}
 
 
-class _ScreamingOperation(op.Operation):
+class _ScreamingOperation(Operation):
     def __init__(self):
         self.name = ("",)
         self.needs = ()

test/test_graphtik.py

@@ -39,7 +39,7 @@
 )
 from graphtik.execution import Solution
 from graphtik.modifiers import optional, sfx, sfxed, vararg
-from graphtik.op import NetworkOperation, Operation
+from graphtik.composition import NetworkOperation, Operation
 
 log = logging.getLogger(__name__)