diff --git a/src/databases/Postgres.ts b/src/databases/Postgres.ts index c0711bb..51b9fdb 100644 --- a/src/databases/Postgres.ts +++ b/src/databases/Postgres.ts @@ -111,8 +111,8 @@ export class Postgres implements IDatabase { private getClient(type: string): Promise { const readAvailable = this.poolRead && (type === "get" || type === "all"); - const ignroreReadDueToFailure = this.lastPoolReadFail < Date.now() - 1000 * 30; - const readDueToFailure = this.lastPoolFail < Date.now() - 1000 * 30; + const ignroreReadDueToFailure = this.lastPoolReadFail > Date.now() - 1000 * 30; + const readDueToFailure = this.lastPoolFail > Date.now() - 1000 * 30; if (readAvailable && !ignroreReadDueToFailure && (readDueToFailure || Math.random() > 1 / (this.config.postgresReadOnly.weight + 1))) { return this.poolRead.connect();