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()