def pipeline(config):
    """
    For UT
    """
    return (
        pipe.input('num')
        .map('num', 'ret', lambda x: x + config.param)
        .output('ret')
    )
For UT
tests/unittests/runtime/builtin_pipeline.py