(no commit message)
authorUnknown Author <unknown>
Tue, 12 Aug 2008 23:20:17 +0000 (23:20 +0000)
committerUnknown Author <unknown>
Tue, 12 Aug 2008 23:20:17 +0000 (23:20 +0000)
htswdataprod/htswdataprod/automation/runner_s.py

index 21f23f88e48ef1a944eec226af8f1e9e334330c6..dc2652212e4c618bc8d464bafd40b46d7738f81b 100644 (file)
@@ -157,13 +157,11 @@ class Runner(rpc.XmlRpcBot):
         #for line in pipe.stdout:
          # self.reportMsg("%s" % (line))
 
-
         for line in pipe.stdout: 
           outBuffer.append("%s" % (line))
           if len(outBuffer)>50:
             self.reportMsg("%s" % ("".join(outBuffer))) 
-            outBuffer = []
-        
+            outBuffer = []        
      
         error_code = pipe.wait()
         self.reportMsg("%s" % ("".join(outBuffer)))        
@@ -177,6 +175,10 @@ class Runner(rpc.XmlRpcBot):
         #fout = open(stdout_filepath, 'r')
         #self.reportMsg(fout.read())
         #fout.close()       
+        
+        #TO DO: Add a nother process: MPListner running in concomitance to MainPiplineSc. When MainPiplineSc finishes kill MPListner.
+        #...
+
  
     def launchJob(self, run_dir,flowcell):
         """