2012-10-25_01_05_01_02_00 :: 1 :: M => 1

pipeline/progs/Quake/bin/quake.py

@@ -427,6 +427,7 @@ def main():
     sys.stderr.flush()
     sys.stdout.flush()
 
+    logDone = open("logdone.log", "w")
     try:
         pcount = 0
         ptotal = len(results)
@@ -447,9 +448,13 @@ def main():
                     resData, resName, resStatus = res
                     if resStatus != 0:
                         print 'list %s returned an error: %d' % ( listFileName, resStatus )
+                        logDone.write('list %s returned an error: %d\n' % ( listFileName, resStatus ))
+                        logDone.flush()
                         sys.exit(1)
                     else:
                         print '%s finished successfully' % listFileName
+                        logDone.write('%s finished successfully\n' % listFileName)
+                        logDone.flush()
                         sys.stderr.flush()
                         sys.stdout.flush()
 
@@ -462,6 +467,12 @@ def main():
                 except:
                     nfo = sys.exc_info()
                     print "threw another exception", nfo[0], nfo[1]
+                    logDone.write("threw another exception ")
+                    logDone.write( nfo[0] )
+                    logDone.write(" ")
+                    logDone.write( nfo[1] )
+                    logDone.write("\n")
+                    logDone.flush()
                     raise
                     sys.exit(1)
 
@@ -474,6 +485,8 @@ def main():
         sys.exit(1)
 
     print 'joining'
+    logDone.write('joining\n')
+    logDone.flush()
     sys.stderr.flush()
     sys.stdout.flush()
     pool.join()
@@ -481,6 +494,8 @@ def main():
     sys.stderr.flush()
     sys.stdout.flush()
     print 'checking files'
+    logDone.write('checking files\n')
+    logDone.flush()
 
     maxWaitingTime = 5 * 60 # 1 min
     for data in readsSplits:
@@ -494,6 +509,8 @@ def main():
                         if compulsory:
                             if not os.path.exists(tmpFile):
                                 print "failed to create tmp file %s for %s" % ( tmpFile, dstFile )
+                                logDone.write("failed to create tmp file %s for %s\n" % ( tmpFile, dstFile ))
+                                logDone.flush()
                                 sys.exit(4)
 
                             initialT = time.time()
@@ -502,6 +519,8 @@ def main():
                                 timeDiff = time.time() - initialT
                                 if timeDiff > maxWaitingTime:
                                     print "waited for too long for %s to %s" % ( tmpFile, dstFile )
+                                    logDone.write("waited for too long for %s to %s\n" % ( tmpFile, dstFile ))
+                                    logDone.flush()
                                     sys.exit(3)
 
 
@@ -512,7 +531,8 @@ def main():
     print '!'*50
     print 'done'
     print 'bye'
-
+    logDone.write("done\n")
+    logDone.close()
 
 def runAnalysis(setup):
     quality_scale    = setup['quality_scale'  ]