Target formatter for Prefect

_.py

from dask.base import tokenize

class TargetFormatter:
    def __init__(self, *args):
        self.args = args

    def __call__(self, **kwargs):
        args = self.args + ("task_name",)
        ret = [kwargs.get(x) for x in args]
        return tokenize(ret)