next fix
This commit is contained in:
@@ -229,9 +229,12 @@ async def compute_correction_factor(
|
||||
)
|
||||
j = raw if isinstance(raw, dict) else json.loads(raw)
|
||||
factor = float(j.get("correction_factor", 1.0))
|
||||
# JSON z DB má často ISO řetězce; asyncpg u $2/$3 vyžaduje datetime
|
||||
ws = _parse_json_dt(j.get("window_start")) or window_start
|
||||
we = _parse_json_dt(j.get("window_end")) or now
|
||||
log_data = {
|
||||
"window_start": j.get("window_start", window_start),
|
||||
"window_end": j.get("window_end", now),
|
||||
"window_start": ws,
|
||||
"window_end": we,
|
||||
"actual_pv_wh": j.get("actual_pv_wh"),
|
||||
"forecast_pv_wh": j.get("forecast_pv_wh"),
|
||||
"correction_factor": factor,
|
||||
|
||||
Reference in New Issue
Block a user