Skip to content

Commit c0e5a1c

Browse files
dshemetovdsweber2
authored andcommitted
fix: newline shenanigans
1 parent afbfac9 commit c0e5a1c

File tree

2 files changed

+4
-9
lines changed
  • nchs_mortality/delphi_nchs_mortality
  • nwss_wastewater/delphi_nwss

2 files changed

+4
-9
lines changed

nchs_mortality/delphi_nchs_mortality/pull.py

+2-5
Original file line numberDiff line numberDiff line change
@@ -89,11 +89,8 @@ def pull_nchs_mortality_data(socrata_token: str, test_file: Optional[str] = None
8989
Expected column(s) missed, The dataset schema may
9090
have changed. Please investigate and amend the code.
9191
92-
Columns needed:
93-
{'\n'.join(type_dict.keys())}
94-
95-
Columns available:
96-
{'\n'.join(df.columns)}
92+
received={''.join(type_dict.keys())}
93+
expected={''.join(df.columns)}
9794
""") from exc
9895

9996
df = df[keep_columns + ["timestamp", "state"]].set_index("timestamp")

nwss_wastewater/delphi_nwss/pull.py

+2-4
Original file line numberDiff line numberDiff line change
@@ -39,15 +39,13 @@ def convert_df_type(df, type_dict, logger):
3939
try:
4040
df = df.astype(type_dict)
4141
except KeyError as exc:
42-
newline = "\n"
4342
raise KeyError(
4443
f"""
4544
Expected column(s) missed, The dataset schema may
4645
have changed. Please investigate and amend the code.
4746
48-
expected={newline.join(sorted(type_dict.keys()))}
49-
50-
received={newline.join(sorted(df.columns))}
47+
expected={''.join(sorted(type_dict.keys()))}
48+
received={''.join(sorted(df.columns))}
5149
"""
5250
) from exc
5351
if new_columns := set(df.columns) - set(type_dict.keys()):

0 commit comments

Comments
 (0)