Remove setting the input source to None in cleanup.

We still want to call clean up in `run`, but if we set the input source to `None` the pipeline can't be started again.

Author: will-rice

spokestack/pipeline.py

@@ -83,7 +83,6 @@ def cleanup(self) -> None:
 
         self._stages.clear()
         self._input_source.close()
-        self._input_source = None
         self._context.reset()
 
     def event(self, function: Any = None, name: Union[str, None] = None) -> Any:

tests/test_pipeline.py

@@ -70,7 +70,6 @@ def test_cleanup():
 
     pipeline.cleanup()
     assert not pipeline._stages
-    assert not pipeline._input_source
 
 
 def test_events():