Update queue-worker.ts
This commit is contained in:
@@ -531,16 +531,16 @@ async function indexJob(job: Job & { id: string }, document: Document) {
|
|||||||
document.markdown &&
|
document.markdown &&
|
||||||
job.data.team_id === process.env.BACKGROUND_INDEX_TEAM_ID!
|
job.data.team_id === process.env.BACKGROUND_INDEX_TEAM_ID!
|
||||||
) {
|
) {
|
||||||
indexPage({
|
// indexPage({
|
||||||
document: document,
|
// document: document,
|
||||||
originUrl: job.data.crawl_id
|
// originUrl: job.data.crawl_id
|
||||||
? (await getCrawl(job.data.crawl_id))?.originUrl!
|
// ? (await getCrawl(job.data.crawl_id))?.originUrl!
|
||||||
: document.metadata.sourceURL!,
|
// : document.metadata.sourceURL!,
|
||||||
crawlId: job.data.crawl_id,
|
// crawlId: job.data.crawl_id,
|
||||||
teamId: job.data.team_id,
|
// teamId: job.data.team_id,
|
||||||
}).catch((error) => {
|
// }).catch((error) => {
|
||||||
_logger.error("Error indexing page", { error });
|
// _logger.error("Error indexing page", { error });
|
||||||
});
|
// });
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user