get_offline_scores.py

import os
import pickle

import pandas as pd
import wandb
from tqdm import tqdm

dataframe = pd.read_csv("runs_tables/offline_urls.csv")

api = wandb.Api(timeout=29)


def get_run_scores(run_id, is_dt=False):
    run = api.run(run_id)
    score_key = None
    all_scores = []
    max_dt = -1e10

    for k in run.history().keys():
        if "normalized" in k and "score" in k and "std" not in k:
            if is_dt:
                st = k
                if "eval/" in st:
                    st = st.replace("eval/", "")
                target = float(st.split("_")[0])
                if target > max_dt:
                    max_dt = target
                    score_key = k
            else:
                score_key = k
                break
    for _, row in run.history(keys=[score_key], samples=5000).iterrows():
        all_scores.append(row[score_key])
    return all_scores


def process_runs(df):
    algorithms = df["algorithm"].unique()
    datasets = df["dataset"].unique()
    full_scores = {algo: {ds: [] for ds in datasets} for algo in algorithms}
    for _, row in tqdm(
        df.iterrows(), desc="Runs scores downloading", position=0, leave=True
    ):
        full_scores[row["algorithm"]][row["dataset"]].append(
            get_run_scores(row["url"], row["algorithm"] == "DT")
        )
    return full_scores


# Run if runs must be recollected
full_scores = process_runs(dataframe)

os.makedirs("bin", exist_ok=True)

with open("bin/offline_scores.pickle", "wb") as handle:
    pickle.dump(full_scores, handle, protocol=pickle.HIGHEST_PROTOCOL)