def wait(self, timeout=None):
if self._started.isSet() andself._running.isSet() andnot self._pausing.isSet():<EOL><INDENT>self._finished.wait(timeout)<EOL><DEDENT>else:<EOL><INDENT>raise PlumberError<EOL><DEDENT>
Waits (blocks) until a running pipeline finishes.

Arguments:

  - timeout(``int``) [default: ``None``] Specifies the timeout, 
    ``RuntimeError`` will be raised. The default is to wait indefinetely
    for the pipeline to finish.