fix dpath key error

Author: pnilan

airbyte_cdk/sources/declarative/validators/dpath_validator.py

@@ -2,6 +2,7 @@
 # Copyright (c) 2025 Airbyte, Inc., all rights reserved.
 #
 
+import logging
 from dataclasses import dataclass
 from typing import Any, List
 
@@ -11,6 +12,9 @@
 from airbyte_cdk.sources.declarative.validators.validation_strategy import ValidationStrategy
 from airbyte_cdk.sources.declarative.validators.validator import Validator
 
+logger = logging.getLogger("airbyte")
+
+
 @dataclass
 class DpathValidator(Validator):
     """
@@ -49,10 +53,13 @@ def validate(self, input_data: dict[str, Any]) -> None:
                 for value in values:
                     self.strategy.validate(value)
             except KeyError as e:
+                logger.warning(f"Error validating path. Key not found: {e}")
                 return
+
         else:
             try:
                 value = dpath.get(input_data, path)
                 self.strategy.validate(value)
             except KeyError as e:
+                logger.warning(f"Error validating path. Key not found: {e}")
                 return

unit_tests/sources/declarative/validators/test_dpath_validator.py

@@ -34,17 +34,18 @@ def test_given_valid_path_and_input_validate_is_successful(self):
         assert strategy.validate_called
         assert strategy.validated_value
 
-    def test_given_invalid_path_when_validate_then_raise_key_error(self):
+
+class TestDpathValidator(TestCase):
+    def test_given_valid_top_level_path_and_input_validate_is_successful(self):
         strategy = MockValidationStrategy()
-        validator = DpathValidator(field_path=["user", "profile", "phone"], strategy=strategy)
+        validator = DpathValidator(field_path=["user"], strategy=strategy)
 
-        test_data = {"user": {"profile": {"email": "test@example.com"}}}
+        test_data = {"user": {"profile": {"email": "test@example.com", "name": "Test User"}}}
 
-        with pytest.raises(ValueError) as context:
-            validator.validate(test_data)
+        validator.validate(test_data)
 
-        assert "Error validating path" in str(context.value)
-        assert not strategy.validate_called
+        assert strategy.validate_called
+        assert strategy.validated_value
 
     def test_given_strategy_fails_when_validate_then_raise_value_error(self):
         error_message = "Invalid email format"
@@ -53,7 +54,7 @@ def test_given_strategy_fails_when_validate_then_raise_value_error(self):
 
         test_data = {"user": {"email": "invalid-email"}}
 
-        with pytest.raises(ValueError) as context:
+        with pytest.raises(ValueError):
             validator.validate(test_data)
 
         assert strategy.validate_called
@@ -67,15 +68,6 @@ def test_given_empty_path_list_when_validate_then_validate_raises_exception(self
         with pytest.raises(ValueError):
             validator.validate(test_data)
 
-    def test_given_empty_input_data_when_validate_then_validate_raises_exception(self):
-        strategy = MockValidationStrategy()
-        validator = DpathValidator(field_path=["data", "field"], strategy=strategy)
-
-        test_data = {}
-
-        with pytest.raises(ValueError):
-            validator.validate(test_data)
-
     def test_path_with_wildcard_when_validate_then_validate_is_successful(self):
         strategy = MockValidationStrategy()
         validator = DpathValidator(field_path=["users", "*", "email"], strategy=strategy)