diff options
| author | MohamedBassem <me@mbassem.com> | 2024-03-21 03:57:32 +0000 |
|---|---|---|
| committer | MohamedBassem <me@mbassem.com> | 2024-03-21 03:57:32 +0000 |
| commit | 5ea1f48e2359c70844c74708a85a2047fd2984b9 (patch) | |
| tree | 20ffd3de619c0d12b135ef2c42f942168f2e4009 /apps/workers/index.ts | |
| parent | 13ed0720e8157897f3085ad7f7f721ff6e27017b (diff) | |
| download | karakeep-5ea1f48e2359c70844c74708a85a2047fd2984b9.tar.zst | |
fix(workers): Fix the leaky browser instances in workers during development
Diffstat (limited to 'apps/workers/index.ts')
| -rw-r--r-- | apps/workers/index.ts | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/apps/workers/index.ts b/apps/workers/index.ts index 5b6b62d5..4db524ef 100644 --- a/apps/workers/index.ts +++ b/apps/workers/index.ts @@ -2,6 +2,7 @@ import "dotenv/config"; import { CrawlerWorker } from "./crawlerWorker"; import { OpenAiWorker } from "./openaiWorker"; import { SearchIndexingWorker } from "./searchWorker"; +import { shutdownPromise } from "./exit"; async function main() { const [crawler, openai, search] = [ @@ -10,7 +11,10 @@ async function main() { await SearchIndexingWorker.build(), ]; - await Promise.all([crawler.run(), openai.run(), search.run()]); + await Promise.any([ + Promise.all([crawler.run(), openai.run(), search.run()]), + shutdownPromise, + ]); } main(); |
