Transformations fail for oracle tap (#2)

transferwise · May 19, 2020 · fb006ec · fb006ec
1 parent e1a568f
commit fb006ec
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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)