Fix missing imports and erroneously named files.

setup.py

@@ -52,7 +52,8 @@ def run(self):
     author_email = '[email protected]',
     license      = 'MIT',
     long_description = open('README.rst').read(),
-    package_dir  = {'' : 'src'},
+    package_dir  = {'mpipe' : 'src'},
+    packages     = ['mpipe'],
     cmdclass     = { 'clean2' : Clean2, 'test' : Test, },
     classifiers  = [
         'Development Status :: 5 - Production/Stable',

src/FilterStage.py

@@ -1,6 +1,7 @@
 """Implements FilterStage class."""
 
 from .Stage import Stage
+from .FilterWorker import FilterWorker
 
 class FilterStage(Stage):
     """Single worker stage running 

src/FilterWorker.py

@@ -1,6 +1,8 @@
 """Implements FilterWorker class."""
 
+import sys
 from .OrderedWorker import OrderedWorker
+from .Pipeline import Pipeline
 
 class FilterWorker(OrderedWorker):
     """FilterWorker filters input to sub-pipelines."""

src/OrderedStage.py

@@ -1,6 +1,7 @@
 """Implements OrderedStage class."""
 
 from .Stage import Stage
+from .OrderedWorker import OrderedWorker
 
 class OrderedStage(Stage):
     """A specialized :class:`~mpipe.Stage`, 

src/OrderedWorker.py

@@ -1,6 +1,7 @@
 """Implements OrderedWorker class."""
 
 import multiprocessing
+from .TubeP import TubeP
 
 class OrderedWorker(multiprocessing.Process):
     """An OrderedWorker object operates in a stage where the order 

src/TupeP.py → src/TubeP.py

@@ -1,5 +1,7 @@
 """Implements TubeP class."""
 
+import multiprocessing
+
 class TubeP:
     """A unidirectional communication channel 
     using :class:`multiprocessing.Connection` for underlying implementation."""

src/TupeQ.py → src/TubeQ.py

@@ -1,5 +1,7 @@
 """Implements TubeQ class."""
 
+import multiprocessing
+
 class TubeQ:
     """A unidirectional communication channel 
     using :class:`multiprocessing.Queue` for underlying implementation."""

src/UnorderedStage.py

@@ -1,6 +1,7 @@
 """Implements UnorderedStage class."""
 
 from .Stage import Stage
+from .UnorderedWorker import UnorderedWorker
 
 class UnorderedStage(Stage):
     """A specialized :class:`~mpipe.Stage`, 

src/UnorderedWorker.py

@@ -1,6 +1,7 @@
 """Implements UnorderedWorker class."""
 
 import multiprocessing
+from .TubeQ import TubeQ
 
 class UnorderedWorker(multiprocessing.Process):
     """An UnorderedWorker object operates independently of other

src/__init__.py

@@ -2,11 +2,11 @@
 
 __version__ = '1.0.7'
 
-from OrderedWorker import OrderedWorker
-from UnorderedWorker import UnorderedWorker
-from Stage import Stage
-from OrderedStage import OrderedStage
-from UnorderedStage import UnorderedStage
-from Pipeline import Pipeline
-from FilterWorker import FilterWorker
-from FilterStage import FilterStage
+from .OrderedWorker import OrderedWorker
+from .UnorderedWorker import UnorderedWorker
+from .Stage import Stage
+from .OrderedStage import OrderedStage
+from .UnorderedStage import UnorderedStage
+from .Pipeline import Pipeline
+from .FilterWorker import FilterWorker
+from .FilterStage import FilterStage