diff options
| author | Scott Coleman <scott.coleman@bytecode.io> | 2020-03-19 09:14:03 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-03-19 10:14:03 -0400 |
| commit | f012a137927591d5d9068d5d499d424ea4112ea9 (patch) | |
| tree | 8694053f7fbada4a3a2960e5346800f50107dc15 /tap_google_sheets | |
| parent | 4d4082c8296045c6bafd81caee31fb2e52b52a6d (diff) | |
| download | tap-google-sheets-f012a137927591d5d9068d5d499d424ea4112ea9.tar.gz tap-google-sheets-f012a137927591d5d9068d5d499d424ea4112ea9.tar.zst tap-google-sheets-f012a137927591d5d9068d5d499d424ea4112ea9.zip | |
Emit state during incremental sync where bookmark not exceeded (#11)v1.0.1
Diffstat (limited to 'tap_google_sheets')
| -rw-r--r-- | tap_google_sheets/sync.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/tap_google_sheets/sync.py b/tap_google_sheets/sync.py index b77eab3..689be27 100644 --- a/tap_google_sheets/sync.py +++ b/tap_google_sheets/sync.py | |||
| @@ -388,6 +388,8 @@ def sync(client, config, catalog, state): | |||
| 388 | LOGGER.info('last_datetime = {}, this_datetime = {}'.format(last_datetime, this_datetime)) | 388 | LOGGER.info('last_datetime = {}, this_datetime = {}'.format(last_datetime, this_datetime)) |
| 389 | if this_datetime <= last_datetime: | 389 | if this_datetime <= last_datetime: |
| 390 | LOGGER.info('this_datetime <= last_datetime, FILE NOT CHANGED. EXITING.') | 390 | LOGGER.info('this_datetime <= last_datetime, FILE NOT CHANGED. EXITING.') |
| 391 | # Update file_metadata bookmark | ||
| 392 | write_bookmark(state, 'file_metadata', strftime(this_datetime)) | ||
| 391 | return | 393 | return |
| 392 | # Sync file_metadata if selected | 394 | # Sync file_metadata if selected |
| 393 | sync_stream(stream_name, selected_streams, catalog, state, file_metadata_tf, time_extracted) | 395 | sync_stream(stream_name, selected_streams, catalog, state, file_metadata_tf, time_extracted) |