Switch from n_threads to n_processes

Author: anitagraser

qgis_processing/extractPtsAlgorithm.py

@@ -28,6 +28,9 @@
 from .qgisUtils import feature_from_gdf_row
 
 
+CPU_COUNT = os.cpu_count()
+
+
 class ExtractODPtsAlgorithm(TrajectoriesAlgorithm):
     ORIGIN_PTS = "ORIGIN_PTS"
     DESTINATIONS_PTS = "DESTINATIONS_PTS"
@@ -203,7 +206,7 @@ def processTc(self, tc, parameters, context):
         min_duration = self.parameterAsString(parameters, self.MIN_DURATION, context)
         min_duration = pd.Timedelta(min_duration).to_pytimedelta()
 
-        gdf = TrajectoryStopDetector(tc, n_threads=os.cpu_count()).get_stop_points(
+        gdf = TrajectoryStopDetector(tc, n_processes=CPU_COUNT).get_stop_points(
             max_diameter=max_diameter, min_duration=min_duration
         )
         gdf = gdf.convert_dtypes()

qgis_processing/trajectoriesAlgorithm.py

@@ -35,6 +35,8 @@
     "a": 3600 * 24 * 365,
 }
 
+CPU_COUNT = os.cpu_count()
+
 
 class TrajectoriesAlgorithm(QgsProcessingAlgorithm):
     INPUT = "INPUT"
@@ -156,9 +158,8 @@ def create_tc(self, parameters, context):
             )
 
         if self.add_metrics:
-            cpus = os.cpu_count()
-            tc.add_speed(units=tuple(self.speed_units), overwrite=True, n_threads=cpus)
-            tc.add_direction(overwrite=True, n_threads=cpus)
+            tc.add_speed(units=tuple(self.speed_units), overwrite=True, n_processes=CPU_COUNT)
+            tc.add_direction(overwrite=True, n_processes=CPU_COUNT)
         return tc, crs
 
     def get_pt_fields(self, fields_to_add=[]):