diff --git a/app.py b/app.py index 8f895b4..1330ae5 100644 --- a/app.py +++ b/app.py @@ -44,10 +44,10 @@ def shutdown_session(exception=None): def scrape_hours(): logging.info("Scraping hours from sheets...") - clean_past_hours() fetch_reg_facility() fetch_reg_building() fetch_sp_facility() + clean_past_hours() # Scrape capacities every 10 minutes diff --git a/src/scrapers/scraper_helpers.py b/src/scrapers/scraper_helpers.py index 2485ec1..e2ca7e8 100644 --- a/src/scrapers/scraper_helpers.py +++ b/src/scrapers/scraper_helpers.py @@ -1,6 +1,7 @@ import pytz from collections import namedtuple from datetime import datetime, timedelta, timezone +from src.database import db_session from src.models.openhours import OpenHours from src.utils.constants import ( EASTERN_TIMEZONE, @@ -21,6 +22,7 @@ def clean_past_hours(): """ day_unix = unix_time(datetime.now().replace(hour=0, minute=0, second=0, microsecond=0)) - SECONDS_IN_DAY OpenHours.query.filter(OpenHours.end_time <= day_unix).delete() + db_session.commit() def clean_hours(date, facility_id=None, gym_id=None):