diff --git a/lib/db/init.ts b/lib/db/init.ts index b4cdb08..2c021e5 100644 --- a/lib/db/init.ts +++ b/lib/db/init.ts @@ -1,6 +1,6 @@ import { Pool } from "https://deno.land/x/postgres@v0.19.3/mod.ts"; import {postgresConfig} from "lib/db/pgConfig.ts"; -const pool = new Pool(postgresConfig, 10); +const pool = new Pool(postgresConfig, 12); export const db = pool; diff --git a/src/filterWorker.ts b/src/filterWorker.ts index c4ace3c..57487f6 100644 --- a/src/filterWorker.ts +++ b/src/filterWorker.ts @@ -29,7 +29,7 @@ const filterWorker = new Worker( break; } }, - { connection: redis, concurrency: 4, removeOnComplete: { count: 1000 } }, + { connection: redis, concurrency: 2, removeOnComplete: { count: 1000 } }, ); filterWorker.on("active", () => {