fix: preparePipeline

cesco69 · web-flow · commit e4131240e5cb · 2025-08-28T13:59:47.000+02:00
diff --git a/packages/pg/lib/query.js b/packages/pg/lib/query.js
@@ -280,7 +280,11 @@ class Query extends EventEmitter {
       rows: this.rows,
     })
 
-    connection.flush()
+    if (!this.rows) {
+      connection.sync()
+    } else {
+      connection.flush()
+    }
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -280,7 +280,11 @@ class Query extends EventEmitter {`
`280`	`280`	`rows: this.rows,`
`281`	`281`	`})`
`282`	`282`
`283`		`- connection.flush()`
	`283`	`+ if (!this.rows) {`
	`284`	`+ connection.sync()`
	`285`	`+ } else {`
	`286`	`+ connection.flush()`
	`287`	`+ }`
`284`	`288`	`}`
`285`	`289`	`}`
`286`	`290`