Skip to content

Commit 6d0ac6d

Browse files
committed
adjusted val cols
1 parent b96d56c commit 6d0ac6d

1 file changed

Lines changed: 8 additions & 7 deletions

File tree

src/webapp/validation.py

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -158,13 +158,6 @@ def validate_dataset(
158158
) -> Dict[str, Any]:
159159
df = pd.read_csv(filename)
160160
df = df.rename(columns={c: normalize_col(c) for c in df.columns})
161-
162-
canon_to_aliases = {
163-
canon: [normalize_col(alias) for alias in [canon] + spec.get("aliases", [])]
164-
for canon, spec in merged_specs.items()
165-
}
166-
df = rename_columns_to_match_schema(df, canon_to_aliases)
167-
168161
incoming = set(df.columns)
169162

170163
# 1) load schemas
@@ -192,6 +185,14 @@ def validate_dataset(
192185
specs = merge_model_columns(base_schema, ext_schema, institution_id, m.lower())
193186
merged_specs.update(specs)
194187

188+
canon_to_aliases = {
189+
canon: [normalize_col(alias) for alias in [canon] + spec.get("aliases", [])]
190+
for canon, spec in merged_specs.items()
191+
}
192+
df = rename_columns_to_match_schema(df, canon_to_aliases)
193+
194+
incoming = set(df.columns)
195+
195196
# 3) build canon → set(normalized names)
196197
canon_to_norms: Dict[str, set] = {
197198
canon: {normalize_col(alias) for alias in [canon] + spec.get("aliases", [])}

0 commit comments

Comments
 (0)