Commit 665498e8 by Eric Coissac

Delay the logging of the broken pipe error

parent 549cc5c6
......@@ -526,31 +526,32 @@ def run(config):
logger.info(" ".join(command))
try:
if fconvert or rconvert:
if nopipe:
logger.info("Writting transformed sequence files...")
writeToFifo(pairs,forward,reverse,logger)
logger.info("Done.")
logger.info("Starting indexing...")
logger.info(" ".join(command))
os.system(" ".join(command))
else:
if fconvert or rconvert:
if nopipe:
logger.info("Writting transformed sequence files...")
writeToFifo(pairs,forward,reverse,logger)
logger.info("Done.")
logger.info("Starting indexing...")
logger.info(" ".join(command))
os.system(" ".join(command))
else:
try:
logger.info("Starting indexing...")
process=Popen(command)
writeToFifo(pairs,forward,reverse,logger)
process.wait()
logger.info('Done.')
else:
logger.info("Starting indexing...")
logger.info(" ".join(command))
os.system(" ".join(command))
except BrokenPipeError:
process.wait()
logger.info('Done.')
logger.warning("Maximum count of read indexed.")
logger.warning("Indexing stopped but the index is usable.")
else:
logger.info("Starting indexing...")
logger.info(" ".join(command))
os.system(" ".join(command))
except BrokenPipeError:
logger.warning("Maximum count of read indexed.")
logger.warning("Indexing stopped but the index is usable.")
r=Index(output)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment