Update app.py

app.py

@@ -119,13 +119,18 @@ def fetch_actuals_for_period(start_date, end_date):
         timestamps = pd.to_datetime(data['hourly']['time'])
         timestamps = timestamps.tz_localize('Europe/Copenhagen', ambiguous='infer')
 
-        return pd.DataFrame({
+        actuals_df = pd.DataFrame({
             'timestamp': timestamps,
             'actual_temp': data['hourly']['temperature_2m'],
             'actual_wind': data['hourly']['windspeed_10m'],
             'actual_pressure': data['hourly']['pressure_msl'],
             'actual_humidity': data['hourly']['relativehumidity_2m']
         })
+
+        # Filtrer fremtidige timer væk: behold kun observationer op til nuværende time
+        current_hour = now_cph().replace(minute=0, second=0, microsecond=0)
+        actuals_df = actuals_df[actuals_df['timestamp'] <= current_hour]
+        return actuals_df
     except Exception as e:
         print(f"❌ Fejl: {e}")
         return None
@@ -317,6 +322,9 @@ def backfill_historical_data():
         return "❌ Ingen data"
 
     final_df = pd.concat(all_data, ignore_index=True)
+    # Fjern fremtidige tider: behold kun rækker hvor timestamp er mindre eller lig med nuværende time
+    current_hour = now_cph().replace(minute=0, second=0, microsecond=0)
+    final_df = final_df[final_df['timestamp'] <= current_hour]
     # Drop duplicates baseret på timestamp (target tid)
     final_df = final_df.drop_duplicates(subset=['timestamp'], keep='first')
 
@@ -355,6 +363,10 @@ def update_daily():
     if len(merged) == 0:
         return "❌ Ingen match"
 
+    # Fjern fremtidige tider: behold kun rækker hvor timestamp er mindre eller lig med nuværende time
+    current_hour = now_cph().replace(minute=0, second=0, microsecond=0)
+    merged = merged[merged['timestamp'] <= current_hour]
+
     merged['hour'] = merged['reference_time'].dt.hour
     merged['day_of_year'] = merged['reference_time'].dt.dayofyear
     merged['month'] = merged['reference_time'].dt.month