Skip to content

fix(sql): Correct GetLatestForcast logic #118

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
devsjc merged 1 commit into from
Jan 20, 2026
Merged

fix(sql): Correct GetLatestForcast logic #118

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 5 additions & 2 deletions internal/server/postgres/sql/queries/predictions.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -111,6 +111,7 @@ INSERT INTO pred.predicted_generation_values (
SELECT DISTINCT ON (fr.forecaster_name)
f.forecast_uuid,
f.init_time_utc,
f.created_at_utc,
f.source_type_id,
f.geometry_uuid,
fr.forecaster_id,
Expand All @@ -122,17 +123,19 @@ FROM pred.forecasters AS fr
forecast_uuid,
init_time_utc,
source_type_id,
geometry_uuid
geometry_uuid,
UUIDV7_EXTRACT_TIMESTAMP(forecast_uuid) AS created_at_utc
FROM pred.forecasts
WHERE geometry_uuid = $1
AND source_type_id = $2
AND forecaster_id = fr.forecaster_id
AND init_time_utc
<= sqlc.arg(pivot_timestamp)::TIMESTAMP - MAKE_INTERVAL(mins => sqlc.arg(horizon_mins)::INTEGER)
-- AND target_period @> (sqlc.arg(pivot_timestamp)::TIMESTAMP)
ORDER BY init_time_utc DESC
LIMIT 1
) AS f
ORDER BY fr.forecaster_name ASC;
ORDER BY fr.forecaster_name ASC, f.init_time_utc DESC;

-- name: ListForecasts :many
/* ListForecasts retrieves all the forecasts for a given location, source type, and forecaster
Expand Down