inspect_dag_group_run.py

import os
import sys
import joblib

# get dag_group_run hash
dag_group_run_hash = sys.argv[1]
assert len(dag_group_run_hash) == 40

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

# load DAG group run
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}")