mirror/act_runner
1
0
Fork 0
mirror of https://gitea.com/gitea/act_runner.git synced 2025-10-20 00:29:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

go mod

Browse Source
This commit is contained in:
sillyguodong
2023-06-28 15:27:44 +08:00
parent 76af298aa3
commit c3c6747bef
3 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
internal/app/poll/poller.go
View File

@@ -24,8 +24,8 @@ type Poller struct {
cfg *config.Config
}
// taskVersion used to store the version of the last task fetched from the Gitea.
var taskVersion int64
// tasksVersion used to store the version of the last task fetched from the Gitea.
var tasksVersion int64
func New(cfg *config.Config, client client.Client, runner *run.Runner) *Poller {
return &Poller{
@@ -69,7 +69,7 @@ func (p *Poller) fetchTask(ctx context.Context) (*runnerv1.Task, bool) {
defer cancel()
resp, err := p.client.FetchTask(reqCtx, connect.NewRequest(&runnerv1.FetchTaskRequest{
TaskVersion: taskVersion,
TasksVersion: tasksVersion,
}))
if errors.Is(err, context.DeadlineExceeded) {
err = nil
@@ -83,14 +83,14 @@ func (p *Poller) fetchTask(ctx context.Context) (*runnerv1.Task, bool) {
return nil, false
}
taskVersion = resp.Msg.TaskVersion
tasksVersion = resp.Msg.TasksVersion
if resp.Msg.Task == nil {
return nil, false
}
// got a task, set `taskVersion` to zero to focre query db in next request.
taskVersion = 0
// got a task, set `tasksVersion` to zero to focre query db in next request.
tasksVersion = 0
return resp.Msg.Task, true
}