Merge pull request #83 from JarvusInnovations/develop

Release: v0.21.4

Author: themightychris

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)) {