diff --git a/config.yml b/config.yml index 8da4bef..dafc77f 100644 --- a/config.yml +++ b/config.yml @@ -28,10 +28,10 @@ database: timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性,为true时CreatedAt/UpdatedAt/DeletedAt都将失效 model_gateway: - type: "pgsql" - host: "192.168.3.30" - port: "5432" + host: "116.204.74.41" + port: "15432" user: "postgres" - pass: "123456" + pass: "Bjang09@686^*^" name: "model-gateway" prefix: "" role: "master" @@ -50,14 +50,14 @@ database: redis: default: - address: 192.168.3.30:6379 + address: 116.204.74.41:6379 db: 0 consul: - address: 192.168.3.30:8500 + address: 116.204.74.41:8500 jaeger: - addr: 192.168.3.30:4318 + addr: 116.204.74.41:4318 # 本地调试用:可选自动执行 worker/cleaner(默认关闭) asynch: diff --git a/service/task/worker.go b/service/task/worker.go index 20dd537..6ed9db5 100644 --- a/service/task/worker.go +++ b/service/task/worker.go @@ -72,7 +72,9 @@ func (w *asyncWorker) handleOne(ctx context.Context, task *entity.ModelGatewayTa } if !strings.Contains(err.Error(), "Timeout") && - !strings.Contains(err.Error(), "InternalServiceError") { + !strings.Contains(err.Error(), "InternalServiceError") && + !strings.Contains(err.Error(), "Invalid video_url") && + !strings.Contains(err.Error(), "Invalid audio track") { w.failTask(ctx, task, startTime, err.Error()) return } @@ -395,6 +397,7 @@ func InvokeModel(ctx context.Context, model *entity.ModelGatewayModel, body map[ msg := string(b) return nil, fmt.Errorf("模型服务返回非2xx: %d, body=%s", resp.StatusCode, msg) } + g.Log().Debugf(ctx, "[执行任务][模型调用成功] StatusCode=%v", resp.StatusCode) return b, nil }