coder
diff --git a/‎coderd/database/databasefake/databasefake.go
+4 b/‎coderd/database/databasefake/databasefake.go
+4
diff --git a/‎coderd/database/querier.go
+1 b/‎coderd/database/querier.go
+1
diff --git a/‎coderd/database/queries.sql.go
+9 b/‎coderd/database/queries.sql.go
+9
diff --git a/‎coderd/database/queries/agentstats.sql
+3 b/‎coderd/database/queries/agentstats.sql
+3
diff --git a/‎coderd/metricscache/cache.go
+7 b/‎coderd/metricscache/cache.go
+7
@@ -137,6 +137,10 @@ func (q *fakeQuerier) AcquireProvisionerJob(_ context.Context, arg database.Acqu
 	}
 	return database.ProvisionerJob{}, sql.ErrNoRows
 }
+func (q *fakeQuerier) DeleteOldAgentStats(_ context.Context) error {
+	// no-op
+	return nil
+}
 
 func (q *fakeQuerier) InsertAgentStat(_ context.Context, p database.InsertAgentStatParams) (database.AgentStat, error) {
 	q.mutex.Lock()
 
@@ -23,3 +23,6 @@ group by
 	date
 order by
 	date asc;
+
+-- name: DeleteOldAgentStats :exec
+DELETE FROM AGENT_STATS WHERE created_at  < now() - interval '30 days';
@@ -8,6 +8,8 @@ import (
 	"sync/atomic"
 	"time"
 
+	"golang.org/x/xerrors"
+
 	"cdr.dev/slog"
 	"github.com/coder/coder/coderd/database"
 	"github.com/coder/coder/codersdk"
@@ -65,6 +67,11 @@ func fillEmptyDAUDays(rows []database.GetDAUsFromAgentStatsRow) []database.GetDA
 }
 
 func (c *Cache) refresh(ctx context.Context) error {
+	err := c.Database.DeleteOldAgentStats(ctx)
+	if err != nil {
+		return xerrors.Errorf("delete old stats: %w", err)
+	}
+
 	daus, err := c.Database.GetDAUsFromAgentStats(ctx)
 	if err != nil {
 		return err
Original file line number	Diff line number	Diff line change
`@@ -137,6 +137,10 @@ func (q *fakeQuerier) AcquireProvisionerJob(_ context.Context, arg database.Acqu`
`137`	`137`	`}`
`138`	`138`	`return database.ProvisionerJob{}, sql.ErrNoRows`
`139`	`139`	`}`
	`140`	`+func (q *fakeQuerier) DeleteOldAgentStats(_ context.Context) error {`
	`141`	`+ // no-op`
	`142`	`+ return nil`
	`143`	`+}`
`140`	`144`
`141`	`145`	`func (q *fakeQuerier) InsertAgentStat(_ context.Context, p database.InsertAgentStatParams) (database.AgentStat, error) {`
`142`	`146`	`q.mutex.Lock()`