import { WorkerHost } from "@nestjs/bullmq"; import { ConfigService } from "@nestjs/config"; import { Job } from "bullmq"; import { ClsService } from "nestjs-cls"; import { CreditValidatorInterface } from "../../../common/tokens"; import { BaseConfigInterface } from "../../../config/interfaces/base.config.interface"; import { EmbedderService } from "../../../core"; import { KeyConceptRepository } from "../repositories/keyconcept.repository"; export declare const KEYCONCEPT_EMBEDDING_QUEUE = "embedding-keyconcepts"; export declare class KeyConceptEmbeddingProcessor extends WorkerHost { private readonly clsService; private readonly keyConceptRepository; private readonly embedderService; /** See ChunkProcessor: seam, not CompanyService — CompanyModule would mount `companies/*` here. */ private readonly creditValidator?; private readonly rebuildKeyConceptsJobName; constructor(clsService: ClsService, keyConceptRepository: KeyConceptRepository, embedderService: EmbedderService, configService: ConfigService, /** See ChunkProcessor: seam, not CompanyService — CompanyModule would mount `companies/*` here. */ creditValidator?: CreditValidatorInterface); onActive(job: Job): void; onError(job: Job): void; onCompleted(job: Job): void; process(job: Job): Promise<{ processed: number; }>; } //# sourceMappingURL=keyconcept.embedding.processor.d.ts.map