Merge pull request #83 from JarvusInnovations/develop

Release: v0.21.4
JarvusInnovations · Jan 30, 2022 · e859b37 · e859b37
2 parents a664af7 + 71d7b46
commit e859b37
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/backend/commands/singer-target.js b/backend/commands/singer-target.js
@@ -101,11 +101,20 @@ exports.handler = async function singerTarget({
   const clearedSheets = new Set();
   const writtenStreams = new Set();
   for await (const { type, stream, ...message} of readMessages({ jsonlFile })) {
-    const sheet = sheets[stream];
-
     console.log(`${type}\t${stream}`, message);
 
 
+    // ignore state for now
+    if (type == 'STATE') {
+      console.warn('ignoring STATE message');
+      continue;
+    }
+
+
+    // get sheet
+    const sheet = sheets[stream];
+
+
     // create schema if needed
     if (!sheet) {
       if (type == 'SCHEMA') {
@@ -129,13 +138,6 @@ exports.handler = async function singerTarget({
     }
 
 
-    // ignore state for now
-    if (type == 'STATE') {
-      console.warn('ignoring STATE message');
-      continue;
-    }
-
-
     // handle record message
     if (type == 'RECORD') {
       if (deleteMissing && !clearedSheets.has(sheet)) {