@@ -204,6 +204,7 @@ def repo_data_inventory(repo=None, *, repo_cfg=None, in_path=None, registry=None
204204 repo_cfg = coerce_repo_config (repo = repo , repo_cfg = repo_cfg )
205205 root = in_path if in_path is not None else repo_cfg ["root" ]
206206 registry = repo_registry (repo_cfg = repo_cfg )
207+ join_key = repo_cfg .get ("key_column" , "station_id" )
207208
208209 allfiles = _inventory_files (root )
209210 allmeta = _parse_inventory_meta (allfiles , repo_cfg = repo_cfg )
@@ -216,7 +217,6 @@ def repo_data_inventory(repo=None, *, repo_cfg=None, in_path=None, registry=None
216217 metadf ["file_pattern" ] = metadf ["filename" ].map (
217218 lambda x : to_wildcard (x , remove_source = True )
218219 )
219- join_key = repo_cfg .get ("key_column" , "station_id" )
220220 if "agency" not in metadf .columns :
221221 # Reset index if key_column is both an index and a column to avoid ambiguity in merge
222222 if registry .index .name == join_key :
@@ -276,7 +276,7 @@ def repo_data_inventory(repo=None, *, repo_cfg=None, in_path=None, registry=None
276276 "eyear" : "max_year" ,
277277 }
278278 grouped = grouped .rename (columns = rename_map )
279- join_key = repo_cfg . get ( "key_column" , "id" )
279+
280280
281281 if join_key not in grouped .columns :
282282 if join_key == "id" and "station_id" in grouped .columns :
0 commit comments