diff options
Diffstat (limited to 'apps/workers')
| -rw-r--r-- | apps/workers/crawlerWorker.ts | 4 | ||||
| -rw-r--r-- | apps/workers/openaiWorker.ts | 2 |
2 files changed, 3 insertions, 3 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(); diff --git a/apps/workers/openaiWorker.ts b/apps/workers/openaiWorker.ts index 9e6e2f23..55695938 100644 --- a/apps/workers/openaiWorker.ts +++ b/apps/workers/openaiWorker.ts @@ -397,5 +397,5 @@ async function runOpenAI(job: DequeuedJob<ZOpenAIRequest>) { await connectTags(bookmarkId, tags, bookmark.userId); // Update the search index - triggerSearchReindex(bookmarkId); + await triggerSearchReindex(bookmarkId); } |