Tencent/WeKnora · error

failed to enqueue task: %w

Error message

failed to enqueue task: %w

What it means

Thrown when the asynq client fails to enqueue the TypeFAQImport task onto the maintenance queue. Fires when Redis (asynq backend) is down, the queue is misconfigured, or the task ID (taskID:instanceID) already exists; the import is never scheduled.

Source

Thrown at internal/application/service/knowledge_faq_import.go:221

	if payload.DryRun {
		maxRetry = 3 // dry run 重试次数少一些
	}

	// 使用 taskID:instanceID 作为 asynq 的唯一任务标识
	asynqTaskID := fmt.Sprintf("%s:%s", taskID, instanceID)

	task := asynq.NewTask(
		types.TypeFAQImport,
		payloadBytes,
		asynq.TaskID(asynqTaskID),
		asynq.Queue(types.QueueMaintenance),
		asynq.MaxRetry(maxRetry),
		asynq.Timeout(2*time.Hour),
	)
	info, err := s.task.Enqueue(task)
	if err != nil {
		logger.Errorf(ctx, "Failed to enqueue FAQ import task: %v", err)
		return "", fmt.Errorf("failed to enqueue task: %w", err)
	}
	logger.Infof(ctx, "Enqueued FAQ import task: id=%s queue=%s task_id=%s dry_run=%v", info.ID, info.Queue, taskID, payload.DryRun)
	enqueueSucceeded = true

	if !payload.DryRun {
		recordKBActivity(ctx, s.audit, tenantID, kbID, types.AuditActionFAQImportStarted,
			"faq_entry", knowledgeID, types.AuditOutcomeAccepted,
			map[string]any{
				"task_id": taskID, "mode": payload.Mode, "total": len(payload.Entries),
				"trigger": kbActivityTrigger(ctx), "processing_status": "pending",
			})
	}

	return taskID, nil
}

// generateFailedEntriesCSV 生成失败条目的 CSV 文件并上传
func (s *knowledgeService) generateFailedEntriesCSV(ctx context.Context,

View on GitHub (pinned to 988cbb0330)

Solutions

1. Check Redis connectivity and asynq configuration
2. Verify the QueueMaintenance queue is registered on workers
3. If the task ID collided, wait for the previous task or purge it before retrying
4. Retry the import request once the broker is healthy

When it happens

Trigger: Thrown at internal/application/service/knowledge_faq_import.go:221 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of Tencent/WeKnora@988cbb0330 (2026-09-02). Data as JSON: /api/errors/883ff72b07daedcd. Report an issue: GitHub.