GuanM/certimate
1
0
Fork 0
mirror of https://github.com/usual2970/certimate.git synced 2025-06-25 05:39:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

recover from panics

Browse Source
This commit is contained in:
Yoan.liu 2025-06-13 13:37:14 +08:00
parent a048eb95a9
commit 081e83e0bf
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
internal/workflow/dispatcher/dispatcher.go
View File

@ -4,8 +4,10 @@ import (
"context"
"errors"
"fmt"
"log"
"os"
"runtime"
"runtime/debug"
"strconv"
"sync"
"time"
@ -209,7 +211,25 @@ func (d *WorkflowDispatcher) dequeueWorker() {
}
func (d *WorkflowDispatcher) work(ctx context.Context, data *WorkflowWorkerData) {
var run *domain.WorkflowRun
var err error
defer func() {
// 捕获 panic，避免影响其他工作流的执行
if r := recover(); r != nil {
log.Default().Println("WorkflowId:", data.WorkflowId, "RunId:", data.RunId)
log.Default().Println("Recovered from panic:", r)
log.Default().Println("Stack trace:", string(debug.Stack()))
if run != nil {
run.Status = domain.WorkflowRunStatusTypeFailed
run.EndedAt = time.Now()
run.Error = fmt.Sprintf("workflow run panic: %v", r)
if _, err := d.workflowRunRepo.Save(ctx, run); err != nil {
log.Default().Println("Failed to save workflow run after panic:", err)
}
}
}
<-d.semaphore
d.workerMutex.Lock()
delete(d.workers, data.WorkflowId)
@ -226,7 +246,7 @@ func (d *WorkflowDispatcher) work(ctx context.Context, data *WorkflowWorkerData)
}()
// 查询 WorkflowRun
run, err := d.workflowRunRepo.GetById(ctx, data.RunId)
run, err = d.workflowRunRepo.GetById(ctx, data.RunId)
if err != nil {
if !(errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded)) {
app.GetLogger().Error(fmt.Sprintf("failed to get workflow run #%s", data.RunId), "err", err)