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