mirror of
https://github.com/go-gitea/gitea
synced 2025-07-27 04:38:36 +00:00
fix: ignore ErrAlreadyInQueue
This commit is contained in:
@@ -6,12 +6,14 @@ package bots
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
bots_model "code.gitea.io/gitea/models/bots"
|
bots_model "code.gitea.io/gitea/models/bots"
|
||||||
"code.gitea.io/gitea/models/db"
|
"code.gitea.io/gitea/models/db"
|
||||||
"code.gitea.io/gitea/modules/graceful"
|
"code.gitea.io/gitea/modules/graceful"
|
||||||
"code.gitea.io/gitea/modules/queue"
|
"code.gitea.io/gitea/modules/queue"
|
||||||
|
|
||||||
"xorm.io/builder"
|
"xorm.io/builder"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -27,9 +29,13 @@ func InitJobEmitter() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func EmitJobsIfReady(runID int64) error {
|
func EmitJobsIfReady(runID int64) error {
|
||||||
return jobEmitterQueue.Push(&jobUpdate{
|
err := jobEmitterQueue.Push(&jobUpdate{
|
||||||
RunID: runID,
|
RunID: runID,
|
||||||
})
|
})
|
||||||
|
if errors.Is(err, queue.ErrAlreadyInQueue) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func jobEmitterQueueHandle(data ...queue.Data) []queue.Data {
|
func jobEmitterQueueHandle(data ...queue.Data) []queue.Data {
|
||||||
|
Reference in New Issue
Block a user