Mirrors/gitea
0
0 Fork 0
mirror of https://github.com/go-gitea/gitea.git synced 2026-10-06 18:57:34 +02:00
Code Issues Activity

Improve FetchTask reliability / performance

Browse Source
This commit is contained in:
Christopher Homberger committed 2025-11-14 16:38:21 +01:00
1 parent 0fb3be7f0e
commit dd29c58bd5
2 files changed
+78 -46
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

routers/api/actions/runner/interceptor.go
+13 -6
View File
@@ -45,14 +45,21 @@ var withRunner = connect.WithInterceptors(connect.UnaryInterceptorFunc(func(unar
return nil, status.Error(codes.Unauthenticated, "unregistered runner")
}
cols := []string{"last_online"}
runner.LastOnline = timeutil.TimeStampNow()
if methodName == "UpdateTask" || methodName == "UpdateLog" {
runner.LastActive = timeutil.TimeStampNow()
// Reduce db writes by only updating last active/online when needed
var cols []string
now := timeutil.TimeStampNow()
if runner.LastActive.AddDuration(actions_model.RunnerOfflineTime/2) < now {
runner.LastOnline = now
cols = append(cols, "last_online")
}
if (methodName == "UpdateTask" || methodName == "UpdateLog") && runner.LastActive.AddDuration(actions_model.RunnerIdleTime/2) < now {
runner.LastActive = now
cols = append(cols, "last_active")
}
if err := actions_model.UpdateRunner(ctx, runner, cols...); err != nil {
log.Error("can't update runner status: %v", err)
if cols != nil {
if err := actions_model.UpdateRunner(ctx, runner, cols...); err != nil {
log.Error("can't update runner status: %v", err)
}
}
ctx = context.WithValue(ctx, runnerCtxKey{}, runner)