diff options
| author | kamtschatka <simon.schatka@gmx.at> | 2024-07-21 23:08:06 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-07-21 22:08:06 +0100 |
| commit | c5c62de28944077004f01960ee9f7e12b7d26c2c (patch) | |
| tree | a31c88ff70938c4afe062afbdb078ea3cb83df9a /apps/workers/crawlerWorker.ts | |
| parent | 4c23ea931dc01e0d99869eb518c85f891d006baa (diff) | |
| download | karakeep-c5c62de28944077004f01960ee9f7e12b7d26c2c.tar.zst | |
fix: async/await issues with the new queue (#319)
Diffstat (limited to 'apps/workers/crawlerWorker.ts')
| -rw-r--r-- | apps/workers/crawlerWorker.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/apps/workers/crawlerWorker.ts b/apps/workers/crawlerWorker.ts index a1917523..bb226a27 100644 --- a/apps/workers/crawlerWorker.ts +++ b/apps/workers/crawlerWorker.ts @@ -653,13 +653,13 @@ async function runCrawler(job: DequeuedJob<ZCrawlLinkRequest>) { // Enqueue openai job (if not set, assume it's true for backward compatibility) if (job.data.runInference !== false) { - OpenAIQueue.enqueue({ + await OpenAIQueue.enqueue({ bookmarkId, }); } // Update the search index - triggerSearchReindex(bookmarkId); + await triggerSearchReindex(bookmarkId); // Do the archival as a separate last step as it has the potential for failure await archivalLogic(); |