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}")