diff options
Diffstat (limited to 'apps/workers/index.ts')
| -rw-r--r-- | apps/workers/index.ts | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/apps/workers/index.ts b/apps/workers/index.ts index e576776a..f9a05e59 100644 --- a/apps/workers/index.ts +++ b/apps/workers/index.ts @@ -1,5 +1,7 @@ import "dotenv/config"; +import { TidyAssetsWorker } from "tidyAssetsWorker"; + import serverConfig from "@hoarder/shared/config"; import logger from "@hoarder/shared/logger"; import { runQueueDBMigrations } from "@hoarder/shared/queues"; @@ -13,21 +15,25 @@ async function main() { logger.info(`Workers version: ${serverConfig.serverVersion ?? "not set"}`); runQueueDBMigrations(); - const [crawler, openai, search] = [ + const [crawler, openai, search, tidyAssets] = [ await CrawlerWorker.build(), OpenAiWorker.build(), SearchIndexingWorker.build(), + TidyAssetsWorker.build(), ]; await Promise.any([ - Promise.all([crawler.run(), openai.run(), search.run()]), + Promise.all([crawler.run(), openai.run(), search.run(), tidyAssets.run()]), shutdownPromise, ]); - logger.info("Shutting down crawler, openai and search workers ..."); + logger.info( + "Shutting down crawler, openai, tidyAssets and search workers ...", + ); crawler.stop(); openai.stop(); search.stop(); + tidyAssets.stop(); } main(); |
