diff --git a/etl/src/data/etl_property_capacities_monthly.py b/etl/src/data/etl_property_capacities_monthly.py index 1af6797..c6a6d1b 100644 --- a/etl/src/data/etl_property_capacities_monthly.py +++ b/etl/src/data/etl_property_capacities_monthly.py @@ -9,7 +9,7 @@ d = data.load() def property_capacities_monthly(id: int, scrapeDate: str): - file = f"etl_property_capacities_monthly_{id}.obj" + file = f"etl_property_capacities_monthly_{id}_{scrapeDate}.obj" obj = etl_cache.openObj(file) if obj: return obj diff --git a/etl/src/data/etl_property_capacities_weekdays.py b/etl/src/data/etl_property_capacities_weekdays.py index 486ab4b..633d054 100644 --- a/etl/src/data/etl_property_capacities_weekdays.py +++ b/etl/src/data/etl_property_capacities_weekdays.py @@ -9,7 +9,7 @@ d = data.load() def property_capacities_weekdays(id: int, scrapeDate: str): - file = f"etl_property_capacities_weekdays_{id}.obj" + file = f"etl_property_capacities_weekdays_{id}_{scrapeDate}.obj" obj = etl_cache.openObj(file) if obj: return obj diff --git a/etl/src/data/etl_region_capacities_monthly.py b/etl/src/data/etl_region_capacities_monthly.py index d2b2b61..873ec16 100644 --- a/etl/src/data/etl_region_capacities_monthly.py +++ b/etl/src/data/etl_region_capacities_monthly.py @@ -11,7 +11,7 @@ d = data.load() def region_capacities_monthly(id: int, scrapeDate_start: str): - file = f"etl_region_capacities_monthly_{id}.obj" + file = f"etl_region_capacities_monthly_{id}_{scrapeDate_start}.obj" obj = etl_cache.openObj(file) if obj: return obj diff --git a/etl/src/data/etl_region_capacities_weekdays.py b/etl/src/data/etl_region_capacities_weekdays.py index 8bdb4f5..fb95225 100644 --- a/etl/src/data/etl_region_capacities_weekdays.py +++ b/etl/src/data/etl_region_capacities_weekdays.py @@ -10,7 +10,7 @@ d = data.load() def region_capacities_weekdays(id: int, scrapeDate_start: str): - file = f"etl_region_capacities_weekdays_{id}.obj" + file = f"etl_region_capacities_weekdays_{id}_{scrapeDate_start}.obj" obj = etl_cache.openObj(file) if obj: return obj diff --git a/etl/src/data/etl_region_movAverage.py b/etl/src/data/etl_region_movAverage.py index a25a052..c0b9577 100644 --- a/etl/src/data/etl_region_movAverage.py +++ b/etl/src/data/etl_region_movAverage.py @@ -10,7 +10,7 @@ d = data.load() def region_movingAverage(id: int, scrape_date_start_min: str): - file = f"etl_region_movingAverage_{id}.obj" + file = f"etl_region_movingAverage_{id}_{scrape_date_start_min}.obj" obj = etl_cache.openObj(file) if obj: return obj