From 394cb33d6cd37e7bed23da118c4c1fe0791034ea Mon Sep 17 00:00:00 2001 From: Ken MacDonald Date: Fri, 7 Mar 2025 11:49:07 -0500 Subject: [PATCH] Updating jump and ramp fitting multiprocessing from forkserver to spawn. --- src/stcal/jump/jump.py | 2 +- src/stcal/ramp_fitting/ols_fit.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/stcal/jump/jump.py b/src/stcal/jump/jump.py index 6c89ccb0..45f457ed 100644 --- a/src/stcal/jump/jump.py +++ b/src/stcal/jump/jump.py @@ -164,7 +164,7 @@ def twopoint_diff_multi(jump_data, twopt_params, data, gdq, readnoise_2d, n_slic slices, yinc = slice_data(twopt_params, data, gdq, readnoise_2d, n_slices) log.info("Creating %d processes for jump detection ", n_slices) - ctx = multiprocessing.get_context("forkserver") + ctx = multiprocessing.get_context("spawn") pool = ctx.Pool(processes=n_slices) ######### JUST FOR DEBUGGING ######################### # pool = ctx.Pool(processes=1) diff --git a/src/stcal/ramp_fitting/ols_fit.py b/src/stcal/ramp_fitting/ols_fit.py index 7880b4f0..12fa169a 100644 --- a/src/stcal/ramp_fitting/ols_fit.py +++ b/src/stcal/ramp_fitting/ols_fit.py @@ -160,7 +160,7 @@ def ols_ramp_fit_multiprocessing( ramp_data, buffsize, save_opt, readnoise_2d, gain_2d, weighting, number_slices ) - ctx = multiprocessing.get_context("forkserver") + ctx = multiprocessing.get_context("spawn") pool = ctx.Pool(processes=number_slices) pool_results = pool.starmap(ols_ramp_fit_single, slices) pool.close()