Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit3321a28

Browse files
committed
ensure that ticks from quartz are dbtimey
1 parentd062501 commit3321a28

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

‎coderd/database/dbpurge/dbpurge.go‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111

1212
"github.com/coder/coder/v2/coderd/database"
1313
"github.com/coder/coder/v2/coderd/database/dbauthz"
14+
"github.com/coder/coder/v2/coderd/database/dbtime"
1415
"github.com/coder/quartz"
1516
)
1617

@@ -47,7 +48,8 @@ func New(ctx context.Context, logger slog.Logger, db database.Store, clk quartz.
4748
returnnil
4849
}
4950

50-
iferr:=tx.DeleteOldWorkspaceAgentLogs(ctx,start.Add(-maxAgentLogAge));err!=nil {
51+
deleteOldWorkspaceAgentLogsBefore:=start.Add(-maxAgentLogAge)
52+
iferr:=tx.DeleteOldWorkspaceAgentLogs(ctx,deleteOldWorkspaceAgentLogsBefore);err!=nil {
5153
returnxerrors.Errorf("failed to delete old workspace agent logs: %w",err)
5254
}
5355
iferr:=tx.DeleteOldWorkspaceAgentStats(ctx);err!=nil {
@@ -78,7 +80,7 @@ func New(ctx context.Context, logger slog.Logger, db database.Store, clk quartz.
7880
return
7981
casetick:=<-ticker.C:
8082
ticker.Stop()
81-
doTick(tick)
83+
doTick(dbtime.Time(tick).UTC())
8284
}
8385
}
8486
}()

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp