Python Parallel Dynamics Simulations
I am trying to get PSSE to run multiple simulations to compare the results to one another. As there will be many simulations, I want to "parallelize" the simulations. I have given multiprocessing.Process and multiprocessing.pool a shot and can not get it working.
Here is base code I've been trying to get to work. It solves and creates an out file in the folder if I have the pool function only iterate once. If I try to change it to multiple values, I start getting invalid temporary file or visual fortran errors.
Do I have something incorrect in the coding? Is my understanding of the pool function not correct?
import psspy,redirect,multiprocessing as m
def run_fault(x):
case, snp, out, log = x
# Redirect output from PSSE to Python
redirect.psse2py()
psspy.psseinit(12000)
# Initialize PSSE
psspy.report_output(2,out,[])
psspy.progress_output(2,out,[])
psspy.alert_output(2,out,[])
psspy.prompt_output(2,out,[])
# Load case
psspy.case(case)
psspy.rstr(snp)
psspy.conl(-1,1,1)
psspy.conl(-1,1,2,[0,0],[100,0,0,100])
psspy.conl(-1,1,3)
# Convert generators:
psspy.cong()
# Solve for dynamics
psspy.ordr()
psspy.fact()
psspy.tysl()
# Initialize and run the case
psspy.strt(0,out)
psspy.run(0,1,1,1,1)
psspy.pssehalt_2()
if __name__ == "__main__":
folder = r"C:\Program Files (x86)\PTI\PSSE32\EXAMPLE\dyn"
redirect.psse2py()
psspy.psseinit()
# Generate processes to run
size = 2
arglist = []
for i in range(size):
arglist.append((folder+`i+1`+r"\savnw.sav",folder+`i+1`+r"\savnw.snp",
folder+`i+1`+r"\savnw.out",folder+`i+1`+r"\savnw.log"))
pool = m.Pool()
P = pool.map(func=run_fault, iterable=arglist)
pool.close()
pool.join()
Any help would be appreciated.
add a comment
