Method RunAsyncImportJob

api/service/skill_library_service.go:429–441

(ctx context.Context, jobID int64)

}

func (s *SkillLibraryService) RunAsyncImportJob(ctx context.Context, jobID int64) {
	if jobID <= 0 {
		return
	}
	go func() {
		defer func() {
			if r := recover(); r != nil {
				logger.Warnf(ctx, "【技能运行】导入任务异步执行panic并已恢复: job_id=%d panic=%v stack=%s", jobID, r, string(debug.Stack()))
			}
		}()
		_ = s.runImportWorker(context.Background(), jobID)
	}()
}