feat: update DpathValidator to skip validation if returned value is falsy

airbyte_cdk/sources/declarative/validators/dpath_validator.py

@@ -47,13 +47,17 @@ def validate(self, input_data: dict[str, Any]) -> None:
         if "*" in path:
             try:
                 values = dpath.values(input_data, path)
+                if not values:
+                    return
                 for value in values:
                     self.strategy.validate(value)
             except KeyError as e:
                 raise ValueError(f"Error validating path '{self.field_path}': {e}")
         else:
             try:
                 value = dpath.get(input_data, path)
+                if not value:
+                    return
                 self.strategy.validate(value)
             except KeyError as e:
                 raise ValueError(f"Error validating path '{self.field_path}': {e}")

unit_tests/sources/declarative/validators/test_dpath_validator.py

@@ -1,3 +1,5 @@
+# Copyright (c) 2025 Airbyte, Inc., all rights reserved.
+
 from unittest import TestCase
 
 import pytest
@@ -90,3 +92,13 @@ def test_path_with_wildcard_when_validate_then_validate_is_successful(self):
         assert strategy.validate_called
         assert strategy.validated_value in ["user1@example.com", "user2@example.com"]
         self.assertIn(strategy.validated_value, ["user1@example.com", "user2@example.com"])
+
+    def test_given_no_values_when_validate_then_validate_is_not_called(self):
+        strategy = MockValidationStrategy()
+        validator = DpathValidator(field_path=["users", "*", "email"], strategy=strategy)
+
+        validator.validate({"users": {}})
+        validator.validate(None)
+        validator.validate({"users": [{"name": "Octavia"}]})
+
+        assert not strategy.validate_called