#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)))
#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):
"""