Merge pull request #674 from aaravnavani/on_fail_enum

Make on_fail an enum

Author: zsimjee

docs/hub/api_reference_markdown/validators.md

@@ -165,7 +165,7 @@ Validates whether the generated code snippet contains any secrets.
     ```py
 
     guard = Guard.from_string(validators=[
-        DetectSecrets(on_fail="fix")
+      DetectSecrets(on_fail=OnFailAction.FIX)
     ])
     guard.parse(
         llm_output=code_snippet,

docs/llm_api_wrappers.md

@@ -134,10 +134,10 @@ guard = Guard.from_string(
     validators=[
         ValidLength(
             min=48,
-            on_fail="fix"
+            on_fail=OnFailAction.FIX
         ),
         ToxicLanguage(
-            on_fail="fix"
+            on_fail=OnFailAction.FIX
         )
     ],
     prompt=prompt
@@ -179,10 +179,10 @@ guard = Guard.from_string(
     validators=[
         ValidLength(
             min=48,
-            on_fail="fix"
+            on_fail=OnFailAction.FIX
         ),
         ToxicLanguage(
-            on_fail="fix"
+            on_fail=OnFailAction.FIX
         )
     ],
     prompt=prompt

guardrails/utils/pydantic_utils/v1.py

@@ -33,7 +33,7 @@
 from guardrails.datatypes import String as StringDataType
 from guardrails.datatypes import Time as TimeDataType
 from guardrails.utils.safe_get import safe_get
-from guardrails.validator_base import Validator
+from guardrails.validator_base import OnFailAction, Validator
 from guardrails.validatorsattr import ValidatorsAttr
 
 
@@ -218,7 +218,9 @@ def process_validators(vals, fld):
             )
             if "validators" not in fld.field_info.extra:
                 fld.field_info.extra["validators"] = []
-            fld.field_info.extra["validators"].append((gd_validator, "reask"))
+            fld.field_info.extra["validators"].append(
+                (gd_validator, OnFailAction.REASK)
+            )
 
     model_fields = {}
     for field_name, field in model.__fields__.items():

guardrails/utils/pydantic_utils/v2.py

@@ -34,7 +34,7 @@
 from guardrails.datatypes import String as StringDataType
 from guardrails.datatypes import Time as TimeDataType
 from guardrails.utils.safe_get import safe_get
-from guardrails.validator_base import Validator
+from guardrails.validator_base import OnFailAction, Validator
 from guardrails.validatorsattr import ValidatorsAttr
 
 DataTypeT = TypeVar("DataTypeT", bound=DataType)
@@ -248,7 +248,9 @@ def process_validators(vals, fld):
             )
             if "validators" not in fld.field_info.json_schema_extra:
                 fld.json_schema_extra["validators"] = []
-            fld.json_schema_extra["validators"].append((gd_validator, "reask"))
+            fld.json_schema_extra["validators"].append(
+                (gd_validator, OnFailAction.REASK)
+            )
 
     model_fields = {}
     for field_name, field in model.model_fields.items():

guardrails/validator_base.py

@@ -1,6 +1,7 @@
 import inspect
 from collections import defaultdict
 from copy import deepcopy
+from enum import Enum
 from string import Template
 from typing import (
     Any,
@@ -373,6 +374,16 @@ class FailResult(ValidationResult):
     fix_value: Optional[Any] = None
 
 
+class OnFailAction(str, Enum):
+    REASK = "reask"
+    FIX = "fix"
+    FILTER = "filter"
+    REFRAIN = "refrain"
+    NOOP = "noop"
+    EXCEPTION = "exception"
+    FIX_REASK = "fix_reask"
+
+
 @dataclass  # type: ignore
 class Validator(Runnable):
     """Base class for validators."""
@@ -384,7 +395,9 @@ class Validator(Runnable):
     required_metadata_keys = []
     _metadata = {}
 
-    def __init__(self, on_fail: Optional[Union[Callable, str]] = None, **kwargs):
+    def __init__(
+        self, on_fail: Optional[Union[Callable, OnFailAction]] = None, **kwargs
+    ):
         # Raise a warning for deprecated validators
 
         # Get class name and rail_alias
@@ -411,8 +424,8 @@ def __init__(self, on_fail: Optional[Union[Callable, str]] = None, **kwargs):
                 )
 
         if on_fail is None:
-            on_fail = "noop"
-        if isinstance(on_fail, str):
+            on_fail = OnFailAction.NOOP
+        if isinstance(on_fail, OnFailAction):
             self.on_fail_descriptor = on_fail
             self.on_fail_method = None
         else:

guardrails/validator_service.py

@@ -3,7 +3,7 @@
 import os
 from concurrent.futures import ProcessPoolExecutor
 from datetime import datetime
-from typing import Any, Dict, List, Optional, Tuple
+from typing import Any, Dict, List, Optional, Tuple, Union
 
 from guardrails.classes.history import Iteration
 from guardrails.datatypes import FieldValidation
@@ -17,6 +17,7 @@
 from guardrails.validator_base import (
     FailResult,
     Filter,
+    OnFailAction,
     PassResult,
     Refrain,
     ValidationResult,
@@ -59,13 +60,13 @@ def perform_correction(
         results: List[FailResult],
         value: Any,
         validator: Validator,
-        on_fail_descriptor: str,
+        on_fail_descriptor: Union[OnFailAction, str],
     ):
-        if on_fail_descriptor == "fix":
+        if on_fail_descriptor == OnFailAction.FIX:
             # FIXME: Should we still return fix_value if it is None?
             # I think we should warn and return the original value.
             return results[0].fix_value
-        elif on_fail_descriptor == "fix_reask":
+        elif on_fail_descriptor == OnFailAction.FIX_REASK:
             # FIXME: Same thing here
             fixed_value = results[0].fix_value
             result = self.execute_validator(
@@ -83,21 +84,21 @@ def perform_correction(
             if validator.on_fail_method is None:
                 raise ValueError("on_fail is 'custom' but on_fail_method is None")
             return validator.on_fail_method(value, results)
-        if on_fail_descriptor == "reask":
+        if on_fail_descriptor == OnFailAction.REASK:
             return FieldReAsk(
                 incorrect_value=value,
                 fail_results=results,
             )
-        if on_fail_descriptor == "exception":
+        if on_fail_descriptor == OnFailAction.EXCEPTION:
             raise ValidationError(
                 "Validation failed for field with errors: "
                 + ", ".join([result.error_message for result in results])
             )
-        if on_fail_descriptor == "filter":
+        if on_fail_descriptor == OnFailAction.FILTER:
             return Filter()
-        if on_fail_descriptor == "refrain":
+        if on_fail_descriptor == OnFailAction.REFRAIN:
             return Refrain()
-        if on_fail_descriptor == "noop":
+        if on_fail_descriptor == OnFailAction.NOOP:
             return value
         else:
             raise ValueError(
@@ -251,7 +252,11 @@ def group_validators(self, validators):
             validators, key=lambda v: (v.on_fail_descriptor, v.override_value_on_pass)
         )
         for (on_fail_descriptor, override_on_pass), group in groups:
-            if override_on_pass or on_fail_descriptor in ["fix", "fix_reask", "custom"]:
+            if override_on_pass or on_fail_descriptor in [
+                OnFailAction.FIX,
+                OnFailAction.FIX_REASK,
+                "custom",
+            ]:
                 for validator in group:
                     yield on_fail_descriptor, [validator]
             else:

guardrails/validators/detect_secrets.py

@@ -47,7 +47,7 @@ class DetectSecrets(Validator):
         ```py
 
         guard = Guard.from_string(validators=[
-            DetectSecrets(on_fail="fix")
+            DetectSecrets(on_fail=OnFailAction.FIX)
         ])
         guard.parse(
             llm_output=code_snippet,

guardrails/validators/ends_with.py

@@ -3,6 +3,7 @@
 from guardrails.logger import logger
 from guardrails.validator_base import (
     FailResult,
+    OnFailAction,
     PassResult,
     ValidationResult,
     Validator,
@@ -26,7 +27,7 @@ class EndsWith(Validator):
         end: The required last element.
     """
 
-    def __init__(self, end: str, on_fail: str = "fix"):
+    def __init__(self, end: str, on_fail: OnFailAction = OnFailAction.FIX):
         super().__init__(
             on_fail=on_fail,
             end=end,

guardrails/validators/reading_time.py

@@ -1,4 +1,4 @@
-from typing import Any, Dict, Optional
+from typing import Any, Callable, Dict, Optional
 
 from guardrails.logger import logger
 from guardrails.validator_base import (
@@ -28,7 +28,7 @@ class ReadingTime(Validator):
         reading_time: The maximum reading time in minutes.
     """
 
-    def __init__(self, reading_time: int, on_fail: Optional[str] = None):
+    def __init__(self, reading_time: int, on_fail: Optional[Callable] = None):
         super().__init__(
             on_fail=on_fail,
             reading_time=reading_time,

guardrails/validatorsattr.py

@@ -7,7 +7,7 @@
 
 from guardrails.constants import hub
 from guardrails.utils.xml_utils import cast_xml_to_string
-from guardrails.validator_base import Validator, ValidatorSpec
+from guardrails.validator_base import OnFailAction, Validator, ValidatorSpec
 
 
 class ValidatorsAttr(pydantic.BaseModel):
@@ -176,7 +176,7 @@ def from_xml(
             key = cast_xml_to_string(key)
             if key.startswith("on-fail-"):
                 on_fail_handler_name = key[len("on-fail-") :]
-                on_fail_handler = value
+                on_fail_handler = OnFailAction(value)
                 on_fail_handlers[on_fail_handler_name] = on_fail_handler
 
         validators, unregistered_validators = cls.get_validators(