Skip to content
This repository has been archived by the owner on Mar 25, 2024. It is now read-only.

Commit

Permalink
unset n_jobs in centroiding, no Parallel multiprocessing in pipeline …
Browse files Browse the repository at this point in the history
…processes
  • Loading branch information
Andrey Samartsev committed Dec 22, 2023
1 parent bdee039 commit 814d427
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion pymepix/processing/logic/centroid_calculator.py
Original file line number Diff line number Diff line change
Expand Up @@ -388,7 +388,8 @@ def perform_centroiding_dbscan(self, chunks):
# return p.map(self.calculate_centroids_dbscan, chunks)

if self.number_of_processes>1:
return Parallel(n_jobs=self.number_of_processes)(delayed(calculate_centroids_dbscan)(c,self.tot_threshold, self._tof_scale, self.epsilon, self.min_samples, self._cent_timewalk_lut) for c in chunks)
# return Parallel(n_jobs=self.number_of_processes)(delayed(calculate_centroids_dbscan)(c,self.tot_threshold, self._tof_scale, self.epsilon, self.min_samples, self._cent_timewalk_lut) for c in chunks)
return Parallel(n_jobs=None)(delayed(calculate_centroids_dbscan)(c,self.tot_threshold, self._tof_scale, self.epsilon, self.min_samples, self._cent_timewalk_lut) for c in chunks)

return map(self.calculate_centroids_dbscan, chunks)

Expand Down

0 comments on commit 814d427

Please sign in to comment.