Kind: Class
Source: atloria-monorepo/apps/api/src/parsing/parsing.queue.ts
Implements: OnModuleInit
Methods
| Method | Signature | Returns |
|---|---|---|
onModuleInit | onModuleInit() | void |
addParseJob | addParseJob(data: ParseJobData) | Promise<{ id: string }> |
getJobStatus | getJobStatus(jobId: string) | Promise<any> |
cancelJob | cancelJob(jobId: string) | Promise<boolean> |
Where it refuses work
ParsingQueuestops the work withErrorwhen!dbJob— “Job not found”.ParsingQueuestops the work withErrorwhen!cloneResult.success.ParsingQueuestops the work withErrorwhen!project || !project.organization.users[0]— “Project owner not found”.ParsingQueuestops the work with an early return when!job.
When something fails
ParsingQueuehandles failure in 4 places: it logs it and continues in 2, and lets it reach the caller in 2.
Referenced By
ParsingModule(MODULE_PROVIDES)ParsingService(DEPENDS_ON)
Was this page helpful?