fix sink schema compare test

meltano · Jun 20, 2023 · bfeb482 · bfeb482
1 parent 7cbf834
commit bfeb482
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/singer_sdk/sinks/core.py b/singer_sdk/sinks/core.py
@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 import abc
+import copy
 import datetime
 import json
 import time
@@ -67,6 +68,7 @@ def __init__(
             "Initializing target sink for stream '%s'...",
             stream_name,
         )
+        self.original_schema = copy.deepcopy(schema)
         self.schema = schema
         if self.include_sdc_metadata_properties:
             self._add_sdc_metadata_to_schema()

diff --git a/singer_sdk/target_base.py b/singer_sdk/target_base.py
@@ -167,7 +167,7 @@ def get_sink(
             return self.add_sink(stream_name, schema, key_properties)
 
         if (
-            existing_sink.schema != schema
+            existing_sink.original_schema != schema
             or existing_sink.key_properties != key_properties
         ):
             self.logger.info(