ParseProcessor

reference

1 min readUpdated 2026-07-29

Kind: Class

Source: atloria-monorepo/apps/parser-orchestrator/src/queue/processors/parse.processor.ts

Implements: OnModuleInit, OnModuleDestroy

Methods

Method	Signature	Returns
`onModuleInit`	`onModuleInit()`	`Promise<void>`
`onModuleDestroy`	`onModuleDestroy()`	`Promise<void>`
`handleParse`	`handleParse(job: Job<ParseJobPayload>)`	`Promise<ParseResult[]>`
`onActive`	`onActive(job: Job<ParseJobPayload>)`	`void`
`onCompleted`	`onCompleted(job: Job<ParseJobPayload>, result: ParseResult[])`	`void`
`onFailed`	`onFailed(job: Job<ParseJobPayload>, error: Error)`	`void`
`onProgress`	`onProgress(job: Job<ParseJobPayload>, progress: number)`	`void`

When something fails

ParseProcessor handles failure in 3 places: it logs it and continues in 2, and lets it reach the caller in 1.

Referenced By

QueueModule (MODULE_PROVIDES)

Was this page helpful?

Download as PDF

ADocs generated by Atloria — from the code, always in sync →