fix(Postgres Chat Memory Node): Do not terminate the connection pool (n…

…8n-io#12674)
onesdata · Jan 17, 2025 · 76ac301 · 76ac301
1 parent fd87232
commit 76ac301
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/packages/@n8n/nodes-langchain/nodes/memory/MemoryPostgresChat/MemoryPostgresChat.node.ts b/packages/@n8n/nodes-langchain/nodes/memory/MemoryPostgresChat/MemoryPostgresChat.node.ts
@@ -115,12 +115,7 @@ export class MemoryPostgresChat implements INodeType {
 			...kOptions,
 		});
 
-		async function closeFunction() {
-			void pool.end();
-		}
-
 		return {
-			closeFunction,
 			response: logWrapper(memory, this),
 		};
 	}

diff --git a/packages/nodes-base/nodes/Postgres/transport/index.ts b/packages/nodes-base/nodes/Postgres/transport/index.ts
@@ -186,7 +186,7 @@ export async function configurePostgres(
 		nodeVersion: options.nodeVersion as unknown as string,
 		fallBackHandler,
 		cleanUpHandler: async ({ db }) => {
-			await db.$pool.end();
+			if (!db.$pool.ended) await db.$pool.end();
 		},
 	});
 }