tksadik92/wrenn-releases
1
0
Fork 0
forked from wrenn/wrenn
Code Pull Requests Activity

Merge pull request 'Minor temporary fix for sitewide metrics' (#11) from patch/analytics into dev

Browse Source 
Reviewed-on: wrenn/sandbox#11
This commit is contained in:
Rafeed M. Bhuiyan
2026-04-04 07:11:49 +00:00
parent ab38c8372c 9a52b47786
commit f57fe85492
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
internal/service/stats.go
View File

@ -117,15 +117,21 @@ func (s *StatsService) GetStats(ctx context.Context, teamID pgtype.UUID, r TimeR
// timeSeriesSQL uses an epoch-floor trick to bucket rows by an arbitrary // timeSeriesSQL uses an epoch-floor trick to bucket rows by an arbitrary
// integer number of seconds without requiring TimescaleDB. // integer number of seconds without requiring TimescaleDB.
// //
// MAX is used instead of AVG so that short-lived running states are not
// averaged down to zero within a bucket. For capacity metrics the peak
// value in each bucket is what matters — AVG with ::INTEGER rounding
// caused running_count, vcpus, and memory to become inconsistent with
// each other (e.g. running=0 but vcpus=1).
//
// $1 = bucket width in seconds (integer) // $1 = bucket width in seconds (integer)
// $2 = team_id // $2 = team_id
// $3 = lookback interval literal (e.g. '1 hour') // $3 = lookback interval literal (e.g. '1 hour')
const timeSeriesSQL = ` const timeSeriesSQL = `
SELECT SELECT
to_timestamp(floor(extract(epoch FROM sampled_at) / $1) * $1) AS bucket, to_timestamp(floor(extract(epoch FROM sampled_at) / $1) * $1) AS bucket,
AVG(running_count)::INTEGER AS running_count, MAX(running_count) AS running_count,
AVG(vcpus_reserved)::INTEGER AS vcpus_reserved, MAX(vcpus_reserved) AS vcpus_reserved,
AVG(memory_mb_reserved)::INTEGER AS memory_mb_reserved MAX(memory_mb_reserved) AS memory_mb_reserved
FROM sandbox_metrics_snapshots FROM sandbox_metrics_snapshots
WHERE team_id = $2 WHERE team_id = $2
AND sampled_at >= NOW() - $3::INTERVAL AND sampled_at >= NOW() - $3::INTERVAL