Update flushed_state only if state received from tap (#42)

transferwise · Nov 4, 2019 · 68575f2 · 68575f2
1 parent ed14e6f
commit 68575f2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/target_snowflake/__init__.py b/target_snowflake/__init__.py
@@ -325,7 +325,7 @@ def flush_streams(
         # Update flushed streams
         if filter_streams:
             # update flushed_state position if we have state information for the stream
-            if stream in state.get('bookmarks', {}):
+            if state is not None and stream in state.get('bookmarks', {}):
                 # Create bookmark key if not exists
                 if 'bookmarks' not in flushed_state:
                     flushed_state['bookmarks'] = {}