diff --git a/main.py b/main.py
index 2edccf5..46f212a 100644
--- a/main.py
+++ b/main.py
@@ -63,10 +63,18 @@ while True:
             mode_as_binary = 1
         db.store_data('sg_ready', {'mode': mode_as_binary})
 
-        if now.minute == 0 and now.second == 0:
-            start_hour_local = (now + dt.timedelta(hours=1)).replace(minute=0, second=0, microsecond=0)
-            weather = weather_forecaster.get_hourly_forecast(start_hour_local, HORIZON_DAYS)
-            total = pv_plant.get_power(weather)
-            db.store_forecasts('pv_forecast', total)
+    if now >= next_forecast_at:
+        # Start der Prognose: ab der kommenden vollen Stunde
+        start_hour_local = (now + dt.timedelta(hours=1)).replace(minute=0, second=0, microsecond=0)
+        weather = weather_forecaster.get_hourly_forecast(start_hour_local, HORIZON_DAYS)
+        total = pv_plant.get_power(weather)
+        db.store_forecasts('pv_forecast', total)
+
+        # Nächste geplante Ausführung definieren (immer volle Stunde)
+        # Falls wir durch Delay mehrere Stunden verpasst haben, hole auf:
+        while next_forecast_at <= now:
+            next_forecast_at = (next_forecast_at + dt.timedelta(hours=1)).replace(minute=0, second=0, microsecond=0)
+
+
     time.sleep(0.1)