seriesoftubes.tubes

contains useful functions and classes for stringing together input and output via pipes and converting data formats on the fly

seriesoftubes.tubes.wait_for_job(job, logs=[], logger=None)

wait for a job (Popen instance) to complete

class seriesoftubes.tubes.polledpipe.PolledPipe(logger=None, level=None)

A PolledPipe object has two attributes:

r - pipe read file descriptor, w - pipe write file descriptor

and three methods:

poll() – poll the read end of the pipe, readlines() – read availble lines if the poll says the pipe is ready, log(level=logging.error) – emit the result of readline (if not None)

a select.poll() object has r registered to it

log(level=None)

emit the results of readlines