From fb006ecaa061680b6b423ecfd867439b52616f0a Mon Sep 17 00:00:00 2001 From: Matthew Carter Date: Tue, 19 May 2020 05:24:09 -0400 Subject: [PATCH] Transformations fail for oracle tap (#2) --- tap_oracle/sync_strategies/full_table.py | 4 ++-- tap_oracle/sync_strategies/incremental.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/tap_oracle/sync_strategies/full_table.py b/tap_oracle/sync_strategies/full_table.py index ca614c1..1681fee 100644 --- a/tap_oracle/sync_strategies/full_table.py +++ b/tap_oracle/sync_strategies/full_table.py @@ -46,7 +46,7 @@ def sync_view(conn_config, stream, state, desired_columns): escaped_schema = schema_name escaped_table = stream.table activate_version_message = singer.ActivateVersionMessage( - stream=stream.stream, + stream=stream.tap_stream_id, version=nascent_stream_version) if first_run: @@ -108,7 +108,7 @@ def sync_table(conn_config, stream, state, desired_columns): escaped_schema = schema_name escaped_table = stream.table activate_version_message = singer.ActivateVersionMessage( - stream=stream.stream, + stream=stream.tap_stream_id, version=nascent_stream_version) if first_run: diff --git a/tap_oracle/sync_strategies/incremental.py b/tap_oracle/sync_strategies/incremental.py index 372627c..ca4bdb1 100644 --- a/tap_oracle/sync_strategies/incremental.py +++ b/tap_oracle/sync_strategies/incremental.py @@ -41,7 +41,7 @@ def sync_table(conn_config, stream, state, desired_columns): singer.write_message(singer.StateMessage(value=copy.deepcopy(state))) activate_version_message = singer.ActivateVersionMessage( - stream=stream.stream, + stream=stream.tap_stream_id, version=stream_version) singer.write_message(activate_version_message)