Raise RuntimeError on attempting to iterate non streamable pipelines

Author: gsakkis

pdal/libpdalpython.pyx

@@ -89,6 +89,7 @@ cdef extern from "pdal/PointView.hpp" namespace "pdal":
 cdef extern from "pdal/PipelineManager.hpp" namespace "pdal":
     cdef cppclass PipelineManager:
         const PointViewSet& views() const
+        bool pipelineStreamable() const
 
 
 cdef extern from "pdal/PipelineExecutor.hpp" namespace "pdal":
@@ -207,6 +208,9 @@ cdef class Pipeline(PipelineResultsMixin):
             self._get_json(), chunk_size, prefetch
         )
         self._configure_executor(executor)
+        if not executor.getManagerConst().pipelineStreamable():
+            raise RuntimeError("Pipeline is not streamable")
+
         it = PipelineIterator()
         it.set_executor(executor)
         return it

test/test_pipeline.py

@@ -408,6 +408,12 @@ def test_meshio(self, filename):
 
 
 class TestPipelineIterator:
+    @pytest.mark.parametrize("filename", ["sort.json", "sort.py"])
+    def test_non_streamable(self, filename):
+        r = get_pipeline(filename)
+        with pytest.raises(RuntimeError) as info:
+            r.iterator()
+        assert str(info.value) == "Pipeline is not streamable"
 
     @pytest.mark.parametrize("filename", ["range.json", "range.py"])
     def test_array(self, filename):