def compute_drift_multiple_inst()

in src/drift_detector.py [0:0]

• 10 lines of code
• 5 McCabe index (conditional complexity)

def compute_drift_multiple_inst(train_file, infer_dir):
    """Compute drift for inference datasets"""

    train_df = pd.read_feather(train_file)

    time_range = range(len([f for f in os.listdir(infer_dir) if 'feather' in f]))
    infer_df_list = [pd.read_feather(f'{infer_dir}/{t}.feather') for t in time_range]

    drift_df_list = []
    for t in time_range:
        df = compute_drift(train_df, infer_df_list[t])

        df.index = [t + 1] * len(df)
        drift_df_list.append(df)

    return pd.concat(drift_df_list)