From 030b31c424bc78ffe4fabcd774ab417c5bd64acc Mon Sep 17 00:00:00 2001 From: george haff Date: Thu, 23 Oct 2025 10:11:33 -0400 Subject: [PATCH 1/7] a no-op for now, but allows easy expansion to flu column/signal --- claims_hosp/delphi_claims_hosp/backfill.py | 5 +- claims_hosp/delphi_claims_hosp/config.py | 13 +++-- claims_hosp/delphi_claims_hosp/load_data.py | 4 +- claims_hosp/delphi_claims_hosp/run.py | 52 ++++++++++--------- .../delphi_claims_hosp/update_indicator.py | 8 +-- 5 files changed, 47 insertions(+), 35 deletions(-) diff --git a/claims_hosp/delphi_claims_hosp/backfill.py b/claims_hosp/delphi_claims_hosp/backfill.py index 495abd59b..d14d251b7 100644 --- a/claims_hosp/delphi_claims_hosp/backfill.py +++ b/claims_hosp/delphi_claims_hosp/backfill.py @@ -39,7 +39,8 @@ def store_backfill_file(claims_filepath, _end_date, backfill_dir): backfilldata.rename({"ServiceDate": "time_value", "PatCountyFIPS": "fips", "Denominator": "den", - "Covid_like": "num"}, + "Covid_like": "num", + "Flu1": "num_flu"}, axis=1, inplace=True) backfilldata = gmpr.add_geocode(backfilldata, from_code="fips", new_code="state_id", from_col="fips", new_col="state_id") @@ -49,7 +50,7 @@ def store_backfill_file(claims_filepath, _end_date, backfill_dir): else: _start_date = _end_date.replace(year=_end_date.year-1) selected_columns = ['time_value', 'fips', 'state_id', - 'den', 'num'] + 'den', 'num', 'num_flu'] backfilldata = backfilldata.loc[(backfilldata["time_value"] >= _start_date) & (~backfilldata["fips"].isnull()), selected_columns] diff --git a/claims_hosp/delphi_claims_hosp/config.py b/claims_hosp/delphi_claims_hosp/config.py index b9f1741df..c810b328b 100644 --- a/claims_hosp/delphi_claims_hosp/config.py +++ b/claims_hosp/delphi_claims_hosp/config.py @@ -13,8 +13,14 @@ class Config: """Static configuration variables.""" - signal_name = "smoothed_covid19_from_claims" - signal_weekday_name = "smoothed_adj_covid19_from_claims" + signal_name = { + "Covid_like": "smoothed_covid19_from_claims", + "Flu1": "smoothed_flu_from_claims", + } + signal_weekday_name = { + "Covid_like": "smoothed_adj_covid19_from_claims", + "Flu1": "smoothed_adj_flu_from_claims", + } # max number of CPUs available for pool MAX_CPU_POOL = 10 @@ -30,7 +36,7 @@ class Config: DAY_SHIFT = timedelta(days=0) # data columns - CLAIMS_COUNT_COLS = ["Denominator", "Covid_like"] + CLAIMS_COUNT_COLS = ["Denominator", "Covid_like", "Flu1"] CLAIMS_DATE_COL = "ServiceDate" FIPS_COL = "fips" DATE_COL = "timestamp" @@ -44,6 +50,7 @@ class Config: "PatCountyFIPS": str, "Denominator": float, "Covid_like": float, + "Flu1": float, "PatAgeGroup": str, "Pat HRR ID": str, } diff --git a/claims_hosp/delphi_claims_hosp/load_data.py b/claims_hosp/delphi_claims_hosp/load_data.py index 010d9d61b..564d33079 100644 --- a/claims_hosp/delphi_claims_hosp/load_data.py +++ b/claims_hosp/delphi_claims_hosp/load_data.py @@ -52,7 +52,7 @@ def load_claims_data(claims_filepath, dropdate, base_geo): return claims_data -def load_data(input_filepath, dropdate, base_geo): +def load_data(input_filepath, dropdate, base_geo, numerator_name): """ Load in claims data, and combine them. @@ -71,7 +71,7 @@ def load_data(input_filepath, dropdate, base_geo): # rename numerator and denominator data.fillna(0, inplace=True) - data["num"] = data["Covid_like"] + data["num"] = data[numerator_name] data["den"] = data["Denominator"] data = data[['num', 'den']] data.reset_index(inplace=True) diff --git a/claims_hosp/delphi_claims_hosp/run.py b/claims_hosp/delphi_claims_hosp/run.py index a9752072c..95f336c68 100644 --- a/claims_hosp/delphi_claims_hosp/run.py +++ b/claims_hosp/delphi_claims_hosp/run.py @@ -120,30 +120,34 @@ def run_module(params): else: logger.info("Starting no weekday adj", geo_type=geo) - signal_name = Config.signal_weekday_name if weekday else Config.signal_name - if params["indicator"]["write_se"]: - assert params["indicator"]["obfuscated_prefix"] is not None, \ - "supply obfuscated prefix in params.json" - signal_name = params["indicator"]["obfuscated_prefix"] + "_" + signal_name - - logger.info("Updating signal name", signal=signal_name) - updater = ClaimsHospIndicatorUpdater( - startdate, - enddate, - dropdate, - geo, - params["indicator"]["parallel"], - weekday, - params["indicator"]["write_se"], - signal_name, - logger, - ) - updater.update_indicator( - claims_file, - params["common"]["export_dir"], - ) - max_dates.append(updater.output_dates[-1]) - n_csv_export.append(len(updater.output_dates)) + + for numerator_name in ["Covid_like"]:#^H^H^H, "Flu1"]: + + signal_name = Config.signal_weekday_name[numerator_name] if weekday else Config.signal_name[numerator_name] + if params["indicator"]["write_se"]: + assert params["indicator"]["obfuscated_prefix"] is not None, \ + "supply obfuscated prefix in params.json" + signal_name = params["indicator"]["obfuscated_prefix"] + "_" + signal_name + + logger.info("Updating signal name", signal=signal_name) + updater = ClaimsHospIndicatorUpdater( + startdate, + enddate, + dropdate, + geo, + params["indicator"]["parallel"], + weekday, + params["indicator"]["write_se"], + signal_name, + numerator_name, + logger, + ) + updater.update_indicator( + claims_file, + params["common"]["export_dir"], + ) + max_dates.append(updater.output_dates[-1]) + n_csv_export.append(len(updater.output_dates)) logger.info("Finished updating", geo_type=geo) # Remove all the raw files diff --git a/claims_hosp/delphi_claims_hosp/update_indicator.py b/claims_hosp/delphi_claims_hosp/update_indicator.py index 5ba8ddd22..4b015041a 100644 --- a/claims_hosp/delphi_claims_hosp/update_indicator.py +++ b/claims_hosp/delphi_claims_hosp/update_indicator.py @@ -27,7 +27,7 @@ class ClaimsHospIndicatorUpdater: # pylint: disable=too-many-instance-attributes, too-many-arguments # all variables are used - def __init__(self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, signal_name, logger): + def __init__(self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, signal_name, numerator_name, logger): """ Initialize updater for the claims-based hospitalization indicator. @@ -45,8 +45,8 @@ def __init__(self, startdate, enddate, dropdate, geo, parallel, weekday, write_s self.startdate, self.enddate, self.dropdate = [pd.to_datetime(t) for t in (startdate, enddate, dropdate)] - self.geo, self.parallel, self.weekday, self.write_se, self.signal_name = \ - geo.lower(), parallel, weekday, write_se, signal_name + self.geo, self.parallel, self.weekday, self.write_se, self.signal_name, self.numerator_name = \ + geo.lower(), parallel, weekday, write_se, signal_name, numerator_name # init in shift_dates, declared here for pylint self.burnindate, self.fit_dates, self.burn_in_dates, self.output_dates = \ @@ -147,7 +147,7 @@ def update_indicator(self, input_filepath, outpath): # load data base_geo = Config.HRR_COL if self.geo == Config.HRR_COL else Config.FIPS_COL - data = load_data(input_filepath, self.dropdate, base_geo) + data = load_data(input_filepath, self.dropdate, base_geo, self.numerator_name) data_frame = self.geo_reindex(data) # handle if we need to adjust by weekday From 5bb32e811f96b1fd8471f439da170d6dd02a6d13 Mon Sep 17 00:00:00 2001 From: george haff Date: Thu, 23 Oct 2025 15:51:38 -0400 Subject: [PATCH 2/7] linter pita --- claims_hosp/delphi_claims_hosp/run.py | 5 ++++- claims_hosp/delphi_claims_hosp/update_indicator.py | 3 ++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/claims_hosp/delphi_claims_hosp/run.py b/claims_hosp/delphi_claims_hosp/run.py index 95f336c68..a1122a835 100644 --- a/claims_hosp/delphi_claims_hosp/run.py +++ b/claims_hosp/delphi_claims_hosp/run.py @@ -123,7 +123,10 @@ def run_module(params): for numerator_name in ["Covid_like"]:#^H^H^H, "Flu1"]: - signal_name = Config.signal_weekday_name[numerator_name] if weekday else Config.signal_name[numerator_name] + signal_name = ( + Config.signal_weekday_name[numerator_name] if weekday + else Config.signal_name[numerator_name] + ) if params["indicator"]["write_se"]: assert params["indicator"]["obfuscated_prefix"] is not None, \ "supply obfuscated prefix in params.json" diff --git a/claims_hosp/delphi_claims_hosp/update_indicator.py b/claims_hosp/delphi_claims_hosp/update_indicator.py index 4b015041a..1457d3dfb 100644 --- a/claims_hosp/delphi_claims_hosp/update_indicator.py +++ b/claims_hosp/delphi_claims_hosp/update_indicator.py @@ -27,7 +27,8 @@ class ClaimsHospIndicatorUpdater: # pylint: disable=too-many-instance-attributes, too-many-arguments # all variables are used - def __init__(self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, signal_name, numerator_name, logger): + def __init__(self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, + signal_name, numerator_name, logger): """ Initialize updater for the claims-based hospitalization indicator. From c94c7fb0c9be33cd72daefdd75bfbb98d5e037a1 Mon Sep 17 00:00:00 2001 From: george haff Date: Thu, 23 Oct 2025 16:01:38 -0400 Subject: [PATCH 3/7] update tests w/ new method arguments --- claims_hosp/tests/test_indicator.py | 4 ++-- claims_hosp/tests/test_load_data.py | 6 +++--- claims_hosp/tests/test_update_indicator.py | 6 ++++++ 3 files changed, 11 insertions(+), 5 deletions(-) diff --git a/claims_hosp/tests/test_indicator.py b/claims_hosp/tests/test_indicator.py index c4a8828a6..e3a0c2422 100644 --- a/claims_hosp/tests/test_indicator.py +++ b/claims_hosp/tests/test_indicator.py @@ -20,8 +20,8 @@ class TestLoadData: - fips_data = load_data(DATA_FILEPATH, DROP_DATE, "fips") - hrr_data = load_data(DATA_FILEPATH, DROP_DATE, "hrr") + fips_data = load_data(DATA_FILEPATH, DROP_DATE, "fips", "Covid_like") + hrr_data = load_data(DATA_FILEPATH, DROP_DATE, "hrr", "Covid_like") def test_backwards_pad(self): num0 = np.array([0, 1, 2, 3, 4, 5, 6, 7, 8], dtype=float).reshape(-1, 1) diff --git a/claims_hosp/tests/test_load_data.py b/claims_hosp/tests/test_load_data.py index 4a033804e..2a92eb071 100644 --- a/claims_hosp/tests/test_load_data.py +++ b/claims_hosp/tests/test_load_data.py @@ -21,15 +21,15 @@ class TestLoadData: fips_claims_data = load_claims_data(DATA_FILEPATH, DROP_DATE, "fips") hrr_claims_data = load_claims_data(DATA_FILEPATH, DROP_DATE, "hrr") - fips_data = load_data(DATA_FILEPATH, DROP_DATE, "fips") - hrr_data = load_data(DATA_FILEPATH, DROP_DATE, "hrr") + fips_data = load_data(DATA_FILEPATH, DROP_DATE, "fips", "Covid_like") + hrr_data = load_data(DATA_FILEPATH, DROP_DATE, "hrr", "Covid_like") def test_base_unit(self): with pytest.raises(AssertionError): load_claims_data(DATA_FILEPATH, DROP_DATE, "foo") with pytest.raises(AssertionError): - load_data(DATA_FILEPATH, DROP_DATE, "foo") + load_data(DATA_FILEPATH, DROP_DATE, "foo", "Covid_like") def test_claims_columns(self): assert "hrr" in self.hrr_claims_data.index.names diff --git a/claims_hosp/tests/test_update_indicator.py b/claims_hosp/tests/test_update_indicator.py index 5ca527287..c7ec585b7 100644 --- a/claims_hosp/tests/test_update_indicator.py +++ b/claims_hosp/tests/test_update_indicator.py @@ -52,6 +52,7 @@ def test_shift_dates(self): self.weekday, self.write_se, Config.signal_name, + "Covid_like", TEST_LOGGER ) ## Test init @@ -74,6 +75,7 @@ def test_geo_reindex(self): self.weekday, self.write_se, Config.signal_name, + "Covid_like", TEST_LOGGER ) updater.shift_dates() @@ -93,6 +95,7 @@ def test_update_indicator(self): self.weekday, self.write_se, Config.signal_name, + "Covid_like", TEST_LOGGER ) @@ -115,6 +118,7 @@ def test_write_to_csv_results(self): self.weekday, self.write_se, Config.signal_name, + "Covid_like", TEST_LOGGER ) @@ -196,6 +200,7 @@ def test_write_to_csv_with_se_results(self): True, True, signal_name, + "Covid_like", TEST_LOGGER ) @@ -248,6 +253,7 @@ def test_write_to_csv_wrong_results(self): self.weekday, self.write_se, Config.signal_name, + "Covid_like", TEST_LOGGER ) From cb8fd6c2a96fdce4bcc5867bb32b405bba02091d Mon Sep 17 00:00:00 2001 From: george haff Date: Thu, 23 Oct 2025 16:17:43 -0400 Subject: [PATCH 4/7] more test updates --- claims_hosp/tests/test_backfill.py | 2 +- claims_hosp/tests/test_load_data.py | 2 +- claims_hosp/tests/test_update_indicator.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/claims_hosp/tests/test_backfill.py b/claims_hosp/tests/test_backfill.py index fcd908461..554a1b188 100644 --- a/claims_hosp/tests/test_backfill.py +++ b/claims_hosp/tests/test_backfill.py @@ -37,7 +37,7 @@ def test_store_backfill_file(self): backfill_df = pd.read_parquet(backfill_dir + "/"+ fn, engine='pyarrow') selected_columns = ['time_value', 'fips', 'state_id', - 'num', 'den', 'lag', 'issue_date'] + 'num', 'den', 'lag', 'issue_date', 'num_flu'] assert set(selected_columns) == set(backfill_df.columns) os.remove(backfill_dir + "/" + fn) diff --git a/claims_hosp/tests/test_load_data.py b/claims_hosp/tests/test_load_data.py index 2a92eb071..7641e3434 100644 --- a/claims_hosp/tests/test_load_data.py +++ b/claims_hosp/tests/test_load_data.py @@ -37,7 +37,7 @@ def test_claims_columns(self): assert "timestamp" in self.hrr_claims_data.index.names assert "timestamp" in self.fips_claims_data.index.names - expected_claims_columns = ["Denominator", "Covid_like"] + expected_claims_columns = ["Denominator", "Covid_like", "Flu1"] for col in expected_claims_columns: assert col in self.fips_claims_data.columns assert col in self.hrr_claims_data.columns diff --git a/claims_hosp/tests/test_update_indicator.py b/claims_hosp/tests/test_update_indicator.py index c7ec585b7..7a814db9c 100644 --- a/claims_hosp/tests/test_update_indicator.py +++ b/claims_hosp/tests/test_update_indicator.py @@ -190,7 +190,7 @@ def test_write_to_csv_results(self): def test_write_to_csv_with_se_results(self): obfuscated_name = PARAMS["indicator"]["obfuscated_prefix"] - signal_name = obfuscated_name + "_" + Config.signal_weekday_name + signal_name = obfuscated_name + "_" + Config.signal_weekday_name["Covid_like"] updater = ClaimsHospIndicatorUpdater( "02-01-2020", "06-01-2020", From de94bc6ca8b7a5c5e6808ec92a00b005b29e73f7 Mon Sep 17 00:00:00 2001 From: george haff Date: Thu, 23 Oct 2025 16:29:25 -0400 Subject: [PATCH 5/7] more fun w/ linters (or: how i learned to stop worrying and love stupid conventions and formatting other peoples code) --- claims_hosp/delphi_claims_hosp/backfill.py | 33 +++++++++++-------- claims_hosp/delphi_claims_hosp/run.py | 10 +++--- .../delphi_claims_hosp/update_indicator.py | 15 ++++++--- 3 files changed, 35 insertions(+), 23 deletions(-) diff --git a/claims_hosp/delphi_claims_hosp/backfill.py b/claims_hosp/delphi_claims_hosp/backfill.py index d14d251b7..1b96f9355 100644 --- a/claims_hosp/delphi_claims_hosp/backfill.py +++ b/claims_hosp/delphi_claims_hosp/backfill.py @@ -36,24 +36,29 @@ def store_backfill_file(claims_filepath, _end_date, backfill_dir): dtype=Config.CLAIMS_DTYPES, parse_dates=[Config.CLAIMS_DATE_COL], ) - backfilldata.rename({"ServiceDate": "time_value", - "PatCountyFIPS": "fips", - "Denominator": "den", - "Covid_like": "num", - "Flu1": "num_flu"}, - axis=1, inplace=True) - backfilldata = gmpr.add_geocode(backfilldata, from_code="fips", new_code="state_id", - from_col="fips", new_col="state_id") + backfilldata.rename( + { + "ServiceDate": "time_value", + "PatCountyFIPS": "fips", + "Denominator": "den", + "Covid_like": "num", + "Flu1": "num_flu", + }, + axis=1, + inplace=True + ) + backfilldata = gmpr.add_geocode( + backfilldata, from_code="fips", new_code="state_id", from_col="fips", new_col="state_id" + ) #Store one year's backfill data if _end_date.day == 29 and _end_date.month == 2: _start_date = datetime(_end_date.year-1, 2, 28) else: - _start_date = _end_date.replace(year=_end_date.year-1) - selected_columns = ['time_value', 'fips', 'state_id', - 'den', 'num', 'num_flu'] - backfilldata = backfilldata.loc[(backfilldata["time_value"] >= _start_date) - & (~backfilldata["fips"].isnull()), - selected_columns] + _start_date = _end_date.replace(year=_end_date.year - 1) + selected_columns = ['time_value', 'fips', 'state_id', 'den', 'num', 'num_flu'] + backfilldata = backfilldata.loc[ + (backfilldata["time_value"] >= _start_date) & (~backfilldata["fips"].isnull()), selected_columns + ] backfilldata["lag"] = [(_end_date - x).days for x in backfilldata["time_value"]] backfilldata["time_value"] = backfilldata.time_value.dt.strftime("%Y-%m-%d") diff --git a/claims_hosp/delphi_claims_hosp/run.py b/claims_hosp/delphi_claims_hosp/run.py index a1122a835..581c25308 100644 --- a/claims_hosp/delphi_claims_hosp/run.py +++ b/claims_hosp/delphi_claims_hosp/run.py @@ -121,15 +121,15 @@ def run_module(params): logger.info("Starting no weekday adj", geo_type=geo) - for numerator_name in ["Covid_like"]:#^H^H^H, "Flu1"]: + for numerator_name in ["Covid_like"]: # ^H^H^H^H^H^H, "Flu1"]: signal_name = ( - Config.signal_weekday_name[numerator_name] if weekday - else Config.signal_name[numerator_name] + Config.signal_weekday_name[numerator_name] if weekday else Config.signal_name[numerator_name] ) if params["indicator"]["write_se"]: - assert params["indicator"]["obfuscated_prefix"] is not None, \ - "supply obfuscated prefix in params.json" + assert ( + params["indicator"]["obfuscated_prefix"] is not None + ), "supply obfuscated prefix in params.json" signal_name = params["indicator"]["obfuscated_prefix"] + "_" + signal_name logger.info("Updating signal name", signal=signal_name) diff --git a/claims_hosp/delphi_claims_hosp/update_indicator.py b/claims_hosp/delphi_claims_hosp/update_indicator.py index 1457d3dfb..e44a49ec4 100644 --- a/claims_hosp/delphi_claims_hosp/update_indicator.py +++ b/claims_hosp/delphi_claims_hosp/update_indicator.py @@ -27,8 +27,9 @@ class ClaimsHospIndicatorUpdater: # pylint: disable=too-many-instance-attributes, too-many-arguments # all variables are used - def __init__(self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, - signal_name, numerator_name, logger): + def __init__( + self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, signal_name, numerator_name, logger + ): """ Initialize updater for the claims-based hospitalization indicator. @@ -46,8 +47,14 @@ def __init__(self, startdate, enddate, dropdate, geo, parallel, weekday, write_s self.startdate, self.enddate, self.dropdate = [pd.to_datetime(t) for t in (startdate, enddate, dropdate)] - self.geo, self.parallel, self.weekday, self.write_se, self.signal_name, self.numerator_name = \ - geo.lower(), parallel, weekday, write_se, signal_name, numerator_name + self.geo, self.parallel, self.weekday, self.write_se, self.signal_name, self.numerator_name = ( + geo.lower(), + parallel, + weekday, + write_se, + signal_name, + numerator_name + ) # init in shift_dates, declared here for pylint self.burnindate, self.fit_dates, self.burn_in_dates, self.output_dates = \ From b1a1a14006f522cc8fbe2418c5cb1044d41f4e57 Mon Sep 17 00:00:00 2001 From: george haff Date: Thu, 23 Oct 2025 16:34:13 -0400 Subject: [PATCH 6/7] grumble grumble --- claims_hosp/delphi_claims_hosp/backfill.py | 4 ++-- claims_hosp/delphi_claims_hosp/update_indicator.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/claims_hosp/delphi_claims_hosp/backfill.py b/claims_hosp/delphi_claims_hosp/backfill.py index 1b96f9355..5e6eb8a3d 100644 --- a/claims_hosp/delphi_claims_hosp/backfill.py +++ b/claims_hosp/delphi_claims_hosp/backfill.py @@ -45,7 +45,7 @@ def store_backfill_file(claims_filepath, _end_date, backfill_dir): "Flu1": "num_flu", }, axis=1, - inplace=True + inplace=True, ) backfilldata = gmpr.add_geocode( backfilldata, from_code="fips", new_code="state_id", from_col="fips", new_col="state_id" @@ -55,7 +55,7 @@ def store_backfill_file(claims_filepath, _end_date, backfill_dir): _start_date = datetime(_end_date.year-1, 2, 28) else: _start_date = _end_date.replace(year=_end_date.year - 1) - selected_columns = ['time_value', 'fips', 'state_id', 'den', 'num', 'num_flu'] + selected_columns = ["time_value", "fips", "state_id", "den", "num", "num_flu"] backfilldata = backfilldata.loc[ (backfilldata["time_value"] >= _start_date) & (~backfilldata["fips"].isnull()), selected_columns ] diff --git a/claims_hosp/delphi_claims_hosp/update_indicator.py b/claims_hosp/delphi_claims_hosp/update_indicator.py index e44a49ec4..0955c2391 100644 --- a/claims_hosp/delphi_claims_hosp/update_indicator.py +++ b/claims_hosp/delphi_claims_hosp/update_indicator.py @@ -28,7 +28,7 @@ class ClaimsHospIndicatorUpdater: # all variables are used def __init__( - self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, signal_name, numerator_name, logger + self, startdate, enddate, dropdate, geo, parallel, weekday, write_se, signal_name, numerator_name, logger ): """ Initialize updater for the claims-based hospitalization indicator. @@ -53,7 +53,7 @@ def __init__( weekday, write_se, signal_name, - numerator_name + numerator_name, ) # init in shift_dates, declared here for pylint From 657a5524674f961618ab12127955d9217a61bad7 Mon Sep 17 00:00:00 2001 From: george haff Date: Thu, 23 Oct 2025 16:42:14 -0400 Subject: [PATCH 7/7] now that tests & linting pass, actually enable the new flu signal --- claims_hosp/delphi_claims_hosp/run.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/claims_hosp/delphi_claims_hosp/run.py b/claims_hosp/delphi_claims_hosp/run.py index 581c25308..bff4d711a 100644 --- a/claims_hosp/delphi_claims_hosp/run.py +++ b/claims_hosp/delphi_claims_hosp/run.py @@ -121,7 +121,7 @@ def run_module(params): logger.info("Starting no weekday adj", geo_type=geo) - for numerator_name in ["Covid_like"]: # ^H^H^H^H^H^H, "Flu1"]: + for numerator_name in ["Covid_like", "Flu1"]: signal_name = ( Config.signal_weekday_name[numerator_name] if weekday else Config.signal_name[numerator_name]