From 1a55d39adced8bf83950390366c122c4e5e83920 Mon Sep 17 00:00:00 2001 From: Jason Song Date: Mon, 14 Nov 2022 18:10:00 +0800 Subject: [PATCH] fix: ignore ErrAlreadyInQueue --- modules/bots/job_emitter.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/modules/bots/job_emitter.go b/modules/bots/job_emitter.go index 91c8c9f43a..5ecd1414ab 100644 --- a/modules/bots/job_emitter.go +++ b/modules/bots/job_emitter.go @@ -6,12 +6,14 @@ package bots import ( "context" + "errors" "fmt" bots_model "code.gitea.io/gitea/models/bots" "code.gitea.io/gitea/models/db" "code.gitea.io/gitea/modules/graceful" "code.gitea.io/gitea/modules/queue" + "xorm.io/builder" ) @@ -27,9 +29,13 @@ func InitJobEmitter() { } func EmitJobsIfReady(runID int64) error { - return jobEmitterQueue.Push(&jobUpdate{ + err := jobEmitterQueue.Push(&jobUpdate{ RunID: runID, }) + if errors.Is(err, queue.ErrAlreadyInQueue) { + return nil + } + return err } func jobEmitterQueueHandle(data ...queue.Data) []queue.Data {