diff --git a/scraper/daily_import_climate.py b/scraper/daily_import_climate.py index cb63c3b..428f385 100755 --- a/scraper/daily_import_climate.py +++ b/scraper/daily_import_climate.py @@ -94,7 +94,7 @@ class DwdScraper: else: print("ignored") - cur.execute("UPDATE stations SET dwd_last_update = %s WHERE id = %s;", [datetime.datetime.today().isoformat(), curr_station_id]) + cur.execute("UPDATE stations SET dwd_last_update = %s WHERE dwd_id = %s;", [datetime.datetime.today().isoformat(), last_station]) conn.commit() def get_station_to_update(self):