Merge pull request #4 from degreed-data-engineering/Update-state-each…

…-elt

Update state if no full table sync

tap_mssql/sync_strategies/logical.py

@@ -233,7 +233,7 @@ def execute_log_based_sync(self):
 
             if self.catalog_entry.tap_stream_id == "dbo-InputMetadata":
                 prev_converter = modify_ouput_converter(open_conn)
-
+ 
             results = open_conn.execute(ct_sql_query)
 
             row = results.fetchone()
@@ -243,7 +243,10 @@ def execute_log_based_sync(self):
                 counter.tags["database"] = self.database_name
                 counter.tags["table"] = self.table_name
 
+                rows_updated = False # Checks to see if there are any new records.  If not then records state below
+
                 while row:
+                    rows_updated = True
                     counter.increment()
                     desired_columns = []
                     ordered_row = []
@@ -294,11 +297,20 @@ def execute_log_based_sync(self):
                     # do more
                     row = results.fetchone()
 
+                if not rows_updated: # updates the state if no new records have been added
+                    self.current_log_version = self._get_current_log_version() 
+                    self.state = singer.write_bookmark(
+                        self.state,
+                        self.catalog_entry.tap_stream_id,
+                        "current_log_version",
+                        self.current_log_version,
+                    ) 
+
             singer.write_message(singer.StateMessage(value=copy.deepcopy(self.state)))
 
             if self.catalog_entry.tap_stream_id == "dbo-InputMetadata":
                 revert_ouput_converter(open_conn, prev_converter)
-
+        
     def _build_ct_sql_query(self, key_properties):
         """Using Selected columns, return an SQL query to select updated records from Change Tracking"""
         # Order column list in alphabetical order starting with key_properties then other columns