partial wrapper for Task

[daviddwlee84]

Is it possible to do equivalent partial operations on a Prefect task

For example, I have a flow, and I want to pass some tasks as an input argument, but some of the tasks might require additional arguments which I need to specify before hand.

from typing import Type, List
from prefect import task, flow, Task
from functools import partial
import pandas as pd

@task 
def easy_task(df: pd.DataFrame) -> pd.DataFrame:
    return df + 1

@task
def task_require_argument(df: pd.DataFrame, const: int) -> pd.DataFrame:
    return df * const

@flow
def pipeline(df: pd.DataFrame, tasks: List[Type[Task]]) -> List[pd.DataFrame]:
    results = []
    for t in tasks:
        results.append(t(df))
    return results

if __name__ == "__main__":
    df = ...
    pipeline(df, tasks=[easy_task,
                   # Is it possible to do something like this?
                   partial(task_require_argument, const=3)]