farcasclaudiu/Flowise
1
0
Fork 0
mirror of https://github.com/farcasclaudiu/Flowise.git synced 2026-06-28 23:01:09 +03:00
Code Issues Packages Projects Releases Wiki Activity

BugFix/Patch: PostGreSQL Record Manager (#4430)

Browse Source 
* removed the pgcrypto extension creation (Azure bug)

* changing "now" to "extract"
This commit is contained in:
nikitas-novatix
2025-05-27 20:54:00 +02:00
committed by GitHub
parent 729043bcba
commit 7e7ff24941
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/components/nodes/recordmanager/PostgresRecordManager/PostgresRecordManager.ts
+2 -4
View File
@@ -227,8 +227,6 @@ class PostgresRecordManager implements RecordManagerInterface {
const queryRunner = dataSource.createQueryRunner() const queryRunner = dataSource.createQueryRunner()
const tableName = this.sanitizeTableName(this.tableName) const tableName = this.sanitizeTableName(this.tableName)
await queryRunner.query('CREATE EXTENSION IF NOT EXISTS pgcrypto;')
await queryRunner.manager.query(` await queryRunner.manager.query(`
CREATE TABLE IF NOT EXISTS "${tableName}" ( CREATE TABLE IF NOT EXISTS "${tableName}" (
uuid UUID PRIMARY KEY DEFAULT gen_random_uuid(), uuid UUID PRIMARY KEY DEFAULT gen_random_uuid(),
@@ -260,9 +258,9 @@ class PostgresRecordManager implements RecordManagerInterface {
const dataSource = await this.getDataSource() const dataSource = await this.getDataSource()
try { try {
const queryRunner = dataSource.createQueryRunner() const queryRunner = dataSource.createQueryRunner()
const res = await queryRunner.manager.query('SELECT EXTRACT(EPOCH FROM CURRENT_TIMESTAMP) AS now') const res = await queryRunner.manager.query('SELECT EXTRACT(EPOCH FROM CURRENT_TIMESTAMP) AS extract')
await queryRunner.release() await queryRunner.release()
return Number.parseFloat(res[0].now) return Number.parseFloat(res[0].extract)
} catch (error) { } catch (error) {
console.error('Error getting time in PostgresRecordManager:') console.error('Error getting time in PostgresRecordManager:')
throw error throw error