def METHOD_NAME(pipeline, fn, timeout):
    """Run a single benchmark pipeline.
    """
    # Load the benchmark.
    with open(fn) as f:
        in_data = f.read()
    # Extract arguments.
    match = re.search(ARGS_RE, in_data)
    args = match.group(1) if match else ''
    # Run pipeline.
    cmds = [
        c.format(args=args)
        for c in pipeline
    ]
    return run_pipe(cmds, in_data, timeout)