Allow monitoring TG AI retries
Some checks failed
Build and Deploy / build-and-deploy (push) Failing after 5s
Some checks failed
Build and Deploy / build-and-deploy (push) Failing after 5s
This commit is contained in:
@@ -218,14 +218,13 @@ func (c *classifier) classify(ctx context.Context, msg pendingMessage) (json.Raw
|
|||||||
}
|
}
|
||||||
|
|
||||||
job, err := c.ai.CreateJob(ctx, aiservice.CreateJobRequest{
|
job, err := c.ai.CreateJob(ctx, aiservice.CreateJobRequest{
|
||||||
OwnerService: "monitoring-tg",
|
OwnerService: "monitoring-tg",
|
||||||
OwnerRef: fmt.Sprintf("%d", msg.ID),
|
OwnerRef: fmt.Sprintf("%d", msg.ID),
|
||||||
TaskType: "telegram_classification",
|
TaskType: "telegram_classification",
|
||||||
ModelProfile: c.cfg.LLMModel,
|
ModelProfile: c.cfg.LLMModel,
|
||||||
Priority: 5,
|
Priority: 5,
|
||||||
MaxAttempts: 2,
|
MaxAttempts: 2,
|
||||||
Input: body,
|
Input: body,
|
||||||
IdempotencyKey: fmt.Sprintf("monitoring-tg:telegram_classification:%d", msg.ID),
|
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
Reference in New Issue
Block a user