[FEATURE] V1 Validation scaffolding

great_expectations/core/__init__.py

@@ -18,23 +18,25 @@
 from .id_dict import IDDict
 from .run_identifier import RunIdentifier, RunIdentifierSchema
 from .urn import ge_urn
+from .validation import Validation
 
 __all__ = [
     "Domain",
     "ExpectationSuite",
     "ExpectationSuiteSchema",
-    "expectationSuiteSchema",
     "ExpectationSuiteValidationResult",
     "ExpectationSuiteValidationResultSchema",
     "ExpectationValidationResult",
     "ExpectationValidationResultSchema",
-    "expectationSuiteValidationResultSchema",
-    "expectationValidationResultSchema",
-    "get_metric_kwargs_id",
     "IDDict",
     "RunIdentifier",
     "RunIdentifierSchema",
+    "Validation",
+    "expectationSuiteSchema",
+    "expectationSuiteValidationResultSchema",
+    "expectationValidationResultSchema",
     "ge_urn",
+    "get_metric_kwargs_id",
 ]
 
 logger = logging.getLogger(__name__)

great_expectations/core/factory/__init__.py

@@ -1,2 +1,3 @@
 from .checkpoint_factory import CheckpointFactory
 from .suite_factory import SuiteFactory
+from .validation_factory import ValidationFactory

great_expectations/core/factory/validation_factory.py

@@ -0,0 +1,56 @@
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+from great_expectations._docs_decorators import public_api
+from great_expectations.compatibility.typing_extensions import override
+from great_expectations.core.factory.factory import Factory
+
+if TYPE_CHECKING:
+    from great_expectations.core.validation import Validation
+
+
+# TODO: Add analytics as needed
+class ValidationFactory(Factory[Validation]):
+    def __init__(self, store) -> None:
+        # TODO: Update type hints when new ValidationStore is implemented
+        self._store = store
+
+    @public_api
+    @override
+    def add(self, validation: Validation) -> Validation:
+        """Add a Validation to the collection.
+
+        Parameters:
+            validation: Validation to add
+
+        Raises:
+            DataContextError if Validation already exists
+        """
+        raise NotImplementedError
+
+    @public_api
+    @override
+    def delete(self, validation: Validation) -> Validation:
+        """Delete a Validation from the collection.
+
+        Parameters:
+            validation: Validation to delete
+
+        Raises:
+            DataContextError if Validation doesn't exist
+        """
+        raise NotImplementedError
+
+    @public_api
+    @override
+    def get(self, name: str) -> Validation:
+        """Get a Validation from the collection by name.
+
+        Parameters:
+            name: Name of Validation to get
+
+        Raises:
+            DataContextError when Validation is not found.
+        """
+        raise NotImplementedError

great_expectations/core/validation.py

@@ -0,0 +1,45 @@
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+if TYPE_CHECKING:
+    from great_expectations.core.batch_config import BatchConfig
+    from great_expectations.core.expectation_suite import ExpectationSuite
+    from great_expectations.datasource.fluent.interfaces import DataAsset
+
+
+class Validation:
+    """
+    Responsible for running a suite against data and returning a validation result.
+
+    Args:
+        name: The name of the validation.
+        data: An asset or batch config to validate.
+        suite: A grouping of expectations to validate against the data.
+
+    """
+
+    def __init__(
+        self,
+        name: str,
+        data: DataAsset | BatchConfig,
+        suite: ExpectationSuite,
+    ) -> None:
+        self._name = name
+        self._data = data
+        self._suite = suite
+
+    @property
+    def name(self) -> str:
+        return self._name
+
+    @property
+    def data(self) -> BatchConfig:
+        return self._data
+
+    @property
+    def suite(self) -> ExpectationSuite:
+        return self._suite
+
+    def run(self):
+        raise NotImplementedError

great_expectations/data_context/data_context/abstract_data_context.py

@@ -61,7 +61,11 @@
     _RuntimeEnvironmentConfigurationProvider,
 )
 from great_expectations.core.expectation_validation_result import get_metric_kwargs_id
-from great_expectations.core.factory import CheckpointFactory, SuiteFactory
+from great_expectations.core.factory import (
+    CheckpointFactory,
+    SuiteFactory,
+    ValidationFactory,
+)
 from great_expectations.core.id_dict import BatchKwargs
 from great_expectations.core.serializer import (
     AbstractConfigSerializer,
@@ -329,6 +333,9 @@ def _init_factories(self) -> None:
                 context=self,
             )
 
+        # TODO: Update to follow existing pattern once new ValidationStore is implemented
+        self._validations: ValidationFactory | None = None
+
     def _init_analytics(self) -> None:
         init_analytics(
             data_context_id=uuid.UUID(self._data_context_id),
@@ -555,6 +562,14 @@ def checkpoints(self) -> CheckpointFactory:
             )
         return self._checkpoints
 
+    @property
+    def validations(self) -> ValidationFactory:
+        if not self._validations:
+            raise gx_exceptions.DataContextError(
+                "DataContext requires a configured ValidationStore to persist Validations."
+            )
+        return self._validations
+
     @property
     def expectations_store_name(self) -> Optional[str]:
         return self.variables.expectations_store_name