[BUGFIX] Remettre les options d'execa pour la réplication incrémentale

#270
1024pix · Dec 10, 2024 · 54b6801 · 54b6801
2 parents 79c8fb2 + e65dad9
commit 54b6801
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/steps/incremental.js b/src/steps/incremental.js
@@ -61,8 +61,14 @@ async function run(configuration) {
       `\\copy ${escapeSQLIdentifier(table.name)} from stdin`,
     ];
 
-    const { stdout: copyStdout } = await execa `psql ${copyToStdOutArgs}`
-      .pipe `psql ${copyFromStdInArgs}`;
+    const subprocess = execa({
+      all: true, // join stdout and stderr
+    }) `psql ${copyFromStdInArgs}`;
+    const { stdout: copyStdout } = await execa({
+      stdin: 'ignore', stdout: 'pipe', stderr: 'inherit',
+      buffer: false, // disable execa's buffering otherwise it interferes with the transfer
+    }) `psql ${copyToStdOutArgs}`
+      .pipe(subprocess);
 
     logger.info(`${table.name} table copy returned: ` + copyStdout);