mirror of
https://github.com/Findus23/halo_comparison.git
synced 2024-09-19 16:03:50 +02:00
remove multiprocessing from spectra
This commit is contained in:
parent
082659b2b8
commit
116d94b545
1 changed files with 6 additions and 4 deletions
|
@ -4,7 +4,7 @@
|
|||
|
||||
import itertools
|
||||
import subprocess
|
||||
from multiprocessing import Pool
|
||||
from pathlib import Path
|
||||
from sys import argv
|
||||
|
||||
from jobrun.jobrun import jobrun
|
||||
|
@ -16,7 +16,7 @@ vsc = True
|
|||
|
||||
def spectra_jobrun(args):
|
||||
if vsc:
|
||||
jobrun(args, time="12:00:00", tasks=128, mem=128)
|
||||
jobrun(args, time="12:00:00", tasks=128, mem=128, source=Path("/gpfs/data/fs71636/lwinkler/spack_notes.txt"))
|
||||
else:
|
||||
subprocess.run(args, check=True)
|
||||
|
||||
|
@ -146,5 +146,7 @@ if __name__ == "__main__":
|
|||
args = cross_run(resolutions=resolutions, Lbox=Lbox, time=time)
|
||||
else:
|
||||
raise ValueError("missing argv[2] (power|cross)")
|
||||
with Pool(processes=1) as p:
|
||||
p.starmap(run_spectra, args)
|
||||
for a in args:
|
||||
run_spectra(*a)
|
||||
# with Pool(processes=1) as p:
|
||||
# p.starmap(run_spectra, args)
|
||||
|
|
Loading…
Reference in a new issue