@@ -93,6 +93,10 @@ def load_combined_data(denom_filepath, covid_filepath, base_geo,
93
93
94
94
# Get issue_date from the filename
95
95
issue_date = datetime .strptime (covid_filepath .split ("/" )[- 1 ][:8 ], "%Y%m%d" )
96
+ assert (
97
+ issue_date == datetime .strptime (denom_filepath .split ("/" )[- 1 ][:8 ], "%Y%m%d" )
98
+ ), "The aggregated files used for Covid Claims and Total Claims should have the same drop date."
99
+
96
100
97
101
# load each data stream
98
102
denom_data = load_chng_data (denom_filepath , issue_date , base_geo ,
@@ -137,6 +141,10 @@ def load_cli_data(denom_filepath, flu_filepath, mixed_filepath, flu_like_filepat
137
141
138
142
# Get issue_date from the filename
139
143
issue_date = datetime .strptime (flu_filepath .split ("/" )[- 1 ][:8 ], "%Y%m%d" )
144
+ assert (
145
+ issue_date == datetime .strptime (denom_filepath .split ("/" )[- 1 ][:8 ], "%Y%m%d" )
146
+ ), "The aggregated files used for CLI Claims and Total Claims should have the same drop date."
147
+
140
148
141
149
# load each data stream
142
150
denom_data = load_chng_data (denom_filepath , issue_date , base_geo ,
@@ -188,6 +196,10 @@ def load_flu_data(denom_filepath, flu_filepath, base_geo,
188
196
189
197
# Get issue_date from the filename
190
198
issue_date = datetime .strptime (flu_filepath .split ("/" )[- 1 ][:8 ], "%Y%m%d" )
199
+ assert (
200
+ issue_date == datetime .strptime (denom_filepath .split ("/" )[- 1 ][:8 ], "%Y%m%d" )
201
+ ), "The aggregated files used for Flu Claims and Total Claims should have the same drop date."
202
+
191
203
192
204
# load each data stream
193
205
denom_data = load_chng_data (denom_filepath , issue_date , base_geo ,
0 commit comments