685
def collect_result(cmd, folder_names, jobs=None):
685
def collect_result(cmd, folder_names=[], jobs=None, main_dir=None):
688
688
run = cmd.results.current['run_name']
689
689
all = Combine_results(run)
692
for Pdir in open(pjoin(cmd.me_dir, 'SubProcesses','subproc.mg')):
692
for Pdir in cmd.get_Pdir():
694
693
P_comb = Combine_results(Pdir)
696
P_path = pjoin(cmd.me_dir, 'SubProcesses', Pdir)
697
G_dir = [G for G in os.listdir(P_path) if G.startswith('G') and
698
os.path.isdir(pjoin(P_path,G))]
701
for line in open(pjoin(P_path, 'symfact.dat')):
702
name, mfactor = line.split()
703
if float(mfactor) < 0:
705
if os.path.exists(pjoin(P_path, 'ajob.no_ps.log')):
708
if not folder_names and not jobs:
710
P_comb.add_results(name, pjoin(P_path,name,'results.dat'), mfactor)
696
for job in filter(lambda j: j['p_dir'] == Pdir, jobs):
697
P_comb.add_results(os.path.basename(job['dirname']),\
698
pjoin(job['dirname'],'results.dat'))
701
for line in open(pjoin(Pdir, 'symfact.dat')):
702
name, mfactor = line.split()
703
if float(mfactor) < 0:
705
if os.path.exists(pjoin(Pdir, 'ajob.no_ps.log')):
712
708
for folder in folder_names:
713
709
if 'G' in folder:
714
710
dir = folder.replace('*', name)
716
712
dir = folder.replace('*', '_G' + name)
717
P_comb.add_results(dir, pjoin(P_path,dir,'results.dat'), mfactor)
720
for job in filter(lambda j: j['p_dir'] == Pdir, jobs):
721
P_comb.add_results(os.path.basename(job['dirname']),\
713
P_comb.add_results(dir, pjoin(Pdir,dir,'results.dat'), mfactor)
715
for job in filter(lambda j: j['p_dir'] == Pdir, jobs):
716
P_comb.add_results(os.path.basename(job['dirname']),\
722
717
pjoin(job['dirname'],'results.dat'))
721
G_dir, mfactors = cmd.get_Gdir(Pdir, symfact=True)
725
path = pjoin(main_dir, os.path.basename(Pdir), os.path.basename(G),'results.dat')
727
path = pjoin(G,'results.dat')
728
P_comb.add_results(os.path.basename(G), path, mfactors[G])
725
730
P_comb.compute_values()
726
731
all.append(P_comb)
727
732
all.compute_values()