feat(targets): Allow users to disable schema validation in targets

singer_sdk/helpers/capabilities.py

@@ -144,6 +144,14 @@
         default=False,
     ),
 ).to_dict()
+TARGET_VALIDATE_SCHEMA_CONFIG = PropertiesList(
+    Property(
+        "validate_records",
+        BooleanType(),
+        description="Whether to validate the schema of the incoming streams.",
+        default=True,
+    ),
+).to_dict()
 
 
 class TargetLoadMethods(str, Enum):
@@ -355,3 +363,6 @@ class TargetCapabilities(CapabilitiesEnum):
 
     #: Allow setting the target schema.
     TARGET_SCHEMA = "target-schema"
+
+    #: Validate the schema of the incoming streams.
+    VALIDATE_SCHEMA = "validate-schema"

singer_sdk/sinks/core.py

@@ -9,6 +9,7 @@
 import json
 import time
 import typing as t
+from functools import cached_property
 from gzip import GzipFile
 from gzip import open as gzip_open
 from types import MappingProxyType
@@ -131,9 +132,6 @@ class Sink(metaclass=abc.ABCMeta):
 
     MAX_SIZE_DEFAULT = 10000
 
-    validate_schema = True
-    """Enable JSON schema record validation."""
-
     validate_field_string_format = False
     """Enable JSON schema format validation, for example `date-time` string fields."""
 
@@ -186,6 +184,15 @@ def __init__(
 
         self._validator: BaseJSONSchemaValidator | None = self.get_validator()
 
+    @cached_property
+    def validate_schema(self) -> bool:
+        """Enable JSON schema record validation.
+
+        Returns:
+            True if JSON schema validation is enabled.
+        """
+        return self.config.get("validate_records", True)
+
     def get_validator(self) -> BaseJSONSchemaValidator | None:
         """Get a record validator for this sink.
 

singer_sdk/target_base.py

@@ -21,6 +21,7 @@
     TARGET_HARD_DELETE_CONFIG,
     TARGET_LOAD_METHOD_CONFIG,
     TARGET_SCHEMA_CONFIG,
+    TARGET_VALIDATE_SCHEMA_CONFIG,
     CapabilitiesEnum,
     PluginCapabilities,
     TargetCapabilities,
@@ -608,6 +609,7 @@ def _merge_missing(source_jsonschema: dict, target_jsonschema: dict) -> None:
 
         _merge_missing(ADD_RECORD_METADATA_CONFIG, config_jsonschema)
         _merge_missing(TARGET_LOAD_METHOD_CONFIG, config_jsonschema)
+        _merge_missing(TARGET_VALIDATE_SCHEMA_CONFIG, config_jsonschema)
 
         capabilities = cls.capabilities
 

tests/core/targets/test_target_sql.py

@@ -46,5 +46,5 @@ class MyTarget(SQLTargetMock, capabilities=capabilities):
         pass
 
     about = MyTarget._get_about_info()
-    default_settings = {"add_record_metadata", "load_method"}
+    default_settings = {"add_record_metadata", "load_method", "validate_schema"}
     assert set(about.settings["properties"]) == expected_settings | default_settings