|
1 | 1 | import datetime |
| 2 | +import getpass |
| 3 | +import hashlib |
2 | 4 | import pathlib |
3 | 5 |
|
4 | 6 | import dpath |
@@ -78,8 +80,12 @@ def create_intake_esm_catalog(config): |
78 | 80 | }, |
79 | 81 | ], |
80 | 82 | } |
81 | | - catalog["id"] = "testcat" |
82 | | - catalog["description"] = f"Test Catalog for Experiment {config['general']['expid']}" |
| 83 | + catalog["id"] = hashlib.sha256( |
| 84 | + f"{config['general']['expid']}_{datetime.datetime.now()}_{getpass.getuser()}".encode() |
| 85 | + ).hexdigest() |
| 86 | + catalog[ |
| 87 | + "description" |
| 88 | + ] = f"Intake-ESM Catalog for Experiment {config['general']['expid']}" |
83 | 89 | catalog["title"] = None |
84 | 90 | catalog["last_updated"] = str(datetime.datetime.now()) |
85 | 91 | catalog_dict = catalog["catalog_dict"] = [] |
@@ -112,12 +118,13 @@ def create_intake_esm_catalog(config): |
112 | 118 | project=config["general"].get("project", "esm_tools"), |
113 | 119 | institution_id="AWI", |
114 | 120 | source_id=f"{config['general']['model']}-{config['general']['version']}", |
115 | | - experiment_id=config["general"]["expid"], |
116 | | - realm=mconfig.get("type", "UNKNOWN"), |
117 | | - time_min=config["general"]["start_date"], |
118 | | - time_max=config["general"]["end_date"], |
| 121 | + experiment_id=str(config["general"]["expid"]), |
| 122 | + realm=str(mconfig.get("type", "UNKNOWN")), |
| 123 | + time_min=str(config["general"]["start_date"]), |
| 124 | + time_max=str(config["general"]["end_date"]), |
119 | 125 | uri=f"file://{output_file}", |
120 | | - _data_format_=xarray_engine, # NOTE(PG): I don't like needing this... |
| 126 | + # _data_format_=xarray_engine, # NOTE(PG): I don't like needing this... |
| 127 | + format=xarray_engine, |
121 | 128 | variable_id=var_list, |
122 | 129 | ) |
123 | 130 | catalog_dict.append(this_asset) |
|
0 commit comments