Tspostat in python. Flexible and incremental
Samo Penic
2018-05-07 c295101c47d518681e143b4afeb294f525f16080
Working example... Debugging.
1 files modified
8 ■■■■ changed files
poststat.py 8 ●●●● patch | view | raw | blame | history
poststat.py
@@ -107,7 +107,7 @@
class PostProcess(multiprocessing.Process):
    def __init__(self, dirlist):
        super(PostProcess, self).__init_
        super(PostProcess, self).__init__()
        self.dirlist=dirlist
    def run(self):
        for d in self.dirlist:
@@ -130,15 +130,15 @@
    django.setup()
    from database import models
    objs=models.Run.objects.order_by('id').all()
    dirlist=[[]]
    dirlist=[[],[],[]]
    for i,obj in enumerate(objs):
        cdir=os.path.join(obj.simulation.directory, obj.subdir)
        dirlist[i%NUM_PROCESSES].append(cdir)
    print(dirlist)
    pp=[]
    for i,d in enumerate(dirlist):
        j=Postprocess(d)
        j=PostProcess(d)
        pp.append(j)
        j.start()
    for i in pp:
        pp.join()
        i.join()