inspect_dag_group_run.py

import sys
import os

dag_group_run_hash = sys.argv[1]

assert len(dag_group_run_hash) == 40
import joblib

file_path = os.path.join(
    os.getenv("HOME"),
    "csst_dag",
    f"{dag_group_run_hash}.joblib",
)

data = joblib.load(file_path)
dag_group_run = data["dag_group_run"]
dag_run_list = data["dag_run_list"]

# print dag_group_run and dag_run_list
print("`dag_group_run`:")
print(f"  - {dag_group_run}")
for dag_run in dag_run_list:
    print(f"  - {dag_run}")