<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def run(pipeline, input_gen, options={}):
 """ Run a pipeline over a input generator a b c d e it is also possible to run any reliure pipeline this way: A B C D E """

    logger = logging.getLogger("reliure.run")
    t0 = time()
    res = [output for output in pipeline(input_gen, **options)]
    logger.info("Pipeline executed in %1.3f sec" % (time() - t0))
    return res