fix condition

faros-ai · Jan 22, 2025 · 2ecb91d · 2ecb91d
1 parent 5e88dfa
commit 2ecb91d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airbyte-local-cli-nodejs/src/utils.ts b/airbyte-local-cli-nodejs/src/utils.ts
@@ -264,7 +264,7 @@ export function processSrcDataByLine(line: string, outputStream: Writable, cfg:
     }
     // RECORD and STATE type messages: write to output file
     else {
-      if (data?.record?.stream) {
+      if (data?.record?.stream && cfg.dstStreamPrefix) {
         data.record.stream = `${cfg.dstStreamPrefix ?? ''}${data.record.stream}`;
       }
       outputStream.write(`${JSON.stringify(data)}\n`);