From 7b7fef55e8229a000496ee0e7819f9f00d8d23d6 Mon Sep 17 00:00:00 2001
From: Rotem Bloom <rockrotem@users.noreply.github.com>
Date: Wed, 29 Nov 2023 21:53:14 +0200
Subject: [PATCH] fix error on postgres when setting query_timeout (#5673)

---
 lib/dialects/postgres/index.js | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/lib/dialects/postgres/index.js b/lib/dialects/postgres/index.js
index 6b577185..4a968da6 100644
--- a/lib/dialects/postgres/index.js
+++ b/lib/dialects/postgres/index.js
@@ -194,7 +194,9 @@ class Client_PG extends Client {
 
     return new Promise(function (resolver, rejecter) {
       const queryStream = connection.query(
-        new PGQueryStream(sql, obj.bindings, options)
+        new PGQueryStream(sql, obj.bindings, options), err => {
+          rejecter(err);
+        }
       );
 
       queryStream.on('error', function (error) {