aboutsummaryrefslogtreecommitdiffstats
path: root/apps/workers/index.ts
diff options
context:
space:
mode:
Diffstat (limited to 'apps/workers/index.ts')
-rw-r--r--apps/workers/index.ts12
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();