Made ORSTools ready for qgis_process

ORStools/proc/directions_lines_proc.py

@@ -252,6 +252,12 @@ def processAlgorithm(
 
             feedback.setProgress(int(100.0 / count * num))
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: dest_id}
 
     @staticmethod

ORStools/proc/directions_points_layer_proc.py

@@ -293,6 +293,12 @@ def sort(f):
 
             feedback.setProgress(int(100.0 / count * num))
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: dest_id}
 
     def displayName(self) -> str:

ORStools/proc/directions_points_layers_proc.py

@@ -267,6 +267,12 @@ def sort_end(f):
             counter += 1
             feedback.setProgress(int(100.0 / route_count * counter))
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: dest_id}
 
     @staticmethod

ORStools/proc/export_proc.py

@@ -154,6 +154,17 @@ def processAlgorithm(
             feedback.reportError(msg)
             logger.log(msg)
 
+        sink_line.flushBuffer()
+        if hasattr(sink_line, 'finalize'):
+            sink_line.finalize()
+        else:
+            del sink_line
+
+        sink_point.flushBuffer()
+        if hasattr(sink_point, 'finalize'):
+            sink_point.finalize()
+        else:
+            del sink_point
         return {self.OUT: dest_id_line, self.OUT_POINT: dest_id_point}
 
     @staticmethod

ORStools/proc/isochrones_layer_proc.py

@@ -213,6 +213,12 @@ def processAlgorithm(
             if int(100.0 / source.featureCount() * num)==100:
                 feedback.pushDebugInfo(str(self.dest_id))
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: self.dest_id}
 
     # noinspection PyUnusedLocal

ORStools/proc/isochrones_point_proc.py

@@ -167,6 +167,12 @@ def processAlgorithm(
             feedback.reportError(msg)
             logger.log(msg, 2)
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: self.dest_id}
 
     # noinspection PyUnusedLocal

ORStools/proc/matrix_proc.py

@@ -216,6 +216,12 @@ def processAlgorithm(
 
                 sink.addFeature(feat)
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: dest_id}
 
     # TODO working source_type and destination_type differ in both name and type from get_fields in directions_core.

ORStools/proc/snap_layer_proc.py

@@ -135,6 +135,12 @@ def processAlgorithm(
             feedback.reportError(msg)
             logger.log(msg)
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: dest_id}
 
     def displayName(self) -> str:

ORStools/proc/snap_point_proc.py

@@ -120,6 +120,12 @@ def processAlgorithm(
             feedback.reportError(msg)
             logger.log(msg)
 
+        sink.flushBuffer()
+        if hasattr(sink, 'finalize'):
+            sink.finalize()
+        else:
+            del sink
+
         return {self.OUT: dest_id}
 
     def displayName(self) -> str: