additional PR feedback

Author: Ananya Joshi

_delphi_utils_python/delphi_utils/flash_eval/eval_day.py

@@ -226,6 +226,7 @@ def flash_eval(lag, day, input_df, signal, params, logger=None):
     Ouput:
     None
     """
+    print("RF")
     if not logger:
         logger = get_structured_logger(
             name=signal,

_delphi_utils_python/delphi_utils/flash_eval/run.py

@@ -5,6 +5,7 @@
 when the module is run with `python -m delphi_utils.flash_eval`.
 """
 from datetime import date
+from collections import defaultdict
 import pandas as pd
 from .. import read_params
 from .eval_day import flash_eval
@@ -20,13 +21,13 @@ def run_module():
     signals = params["flash"]["signals"]
     for signal in signals:
         export_files = read_filenames(params["common"]["export_dir"])
-        days = {}
+        days = defaultdict(list)
         #Concat the data from recent files at nation, state, and county resolution per day.
         for (x, _) in export_files:
             if signal in x and pd.Series([y in x for y in ['state', 'county', 'nation']]).any():
                 day = pd.to_datetime(x.split('_')[0], format="%Y%m%d", errors='raise')
-                days[day] = pd.concat([days.get(day, pd.DataFrame()),
-                                       load_csv(f"{params['common']['export_dir']}/{x}")])
+                days[day].append(load_csv(f"{params['common']['export_dir']}/{x}"))
+        days[day] = pd.concat(days[day])
         for day, input_df in days.items():
             input_df = input_df[['geo_id', 'val']].set_index('geo_id').T
             input_df.index = [day]