Emit state during incremental sync where bookmark not exceeded (#11)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 7fc3f38a4158c39ab34a28e90d557ced1db353cf..2f2993730d8ea67f59e2db90988f1f8b52bcb8c5 100644 (file)
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,8 @@
 # Changelog
 
+## 1.0.1
+  * Emit state file for incremental sync where bookmark not exceeded.
+
 ## 1.0.0
   * No change from `v0.0.4`
 

diff --git a/setup.py b/setup.py
index 5aaf0a5e59487cd94d29f6e0b6919d3cb886cf75..27b8573cf730e7e64d5f0840027e97b708fb47d5 100644 (file)
--- a/setup.py
+++ b/setup.py
@@ -3,7 +3,7 @@
 from setuptools import setup, find_packages
 
 setup(name='tap-google-sheets',
-      version='1.0.0',
+      version='1.0.1',
       description='Singer.io tap for extracting data from the Google Sheets v4 API',
       author='jeff.huth@bytecode.io',
       classifiers=['Programming Language :: Python :: 3 :: Only'],

diff --git a/tap_google_sheets/sync.py b/tap_google_sheets/sync.py
index b77eab38af8c8bc0da5f27caba6057c6e4110d54..689be2785010e122842c33482e9efa6c044b558d 100644 (file)
--- a/tap_google_sheets/sync.py
+++ b/tap_google_sheets/sync.py
@@ -388,6 +388,8 @@ def sync(client, config, catalog, state):
     LOGGER.info('last_datetime = {}, this_datetime = {}'.format(last_datetime, this_datetime))
     if this_datetime <= last_datetime:
         LOGGER.info('this_datetime <= last_datetime, FILE NOT CHANGED. EXITING.')
+        # Update file_metadata bookmark
+        write_bookmark(state, 'file_metadata', strftime(this_datetime))
         return
     # Sync file_metadata if selected
     sync_stream(stream_name, selected_streams, catalog, state, file_metadata_tf, time_extracted)