apply_processors.py

def apply_processors(processors, df, callback=None):
    def _callback(processor, df):
        if callback is None:
            return
        callback(processor, df)

    for fn in processors:
        df = fn(df)
        _callback(fn, df)

    return df.copy()