From bc15c2e11603c1633a02f5390100c2034e37e119 Mon Sep 17 00:00:00 2001 From: Grendgi Date: Mon, 8 Jun 2026 15:48:47 +0300 Subject: [PATCH] Allow monitoring TG AI retries --- cmd/classifier/main.go | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/cmd/classifier/main.go b/cmd/classifier/main.go index cf35f5b..5eb7864 100644 --- a/cmd/classifier/main.go +++ b/cmd/classifier/main.go @@ -218,14 +218,13 @@ func (c *classifier) classify(ctx context.Context, msg pendingMessage) (json.Raw } job, err := c.ai.CreateJob(ctx, aiservice.CreateJobRequest{ - OwnerService: "monitoring-tg", - OwnerRef: fmt.Sprintf("%d", msg.ID), - TaskType: "telegram_classification", - ModelProfile: c.cfg.LLMModel, - Priority: 5, - MaxAttempts: 2, - Input: body, - IdempotencyKey: fmt.Sprintf("monitoring-tg:telegram_classification:%d", msg.ID), + OwnerService: "monitoring-tg", + OwnerRef: fmt.Sprintf("%d", msg.ID), + TaskType: "telegram_classification", + ModelProfile: c.cfg.LLMModel, + Priority: 5, + MaxAttempts: 2, + Input: body, }) if err != nil { return nil, err