Skip to content

exceptions

SchemaValidationError

Bases: Exception

Exception raised for schema validation errors.

Source code in flexible_schema/exceptions.py 
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
class SchemaValidationError(Exception):
    """Exception raised for schema validation errors."""

    def __init__(
        self,
        msg: str | None = None,
        *,
        disallowed_extra_cols: list[str] | None = None,
        missing_req_cols: list[str] | None = None,
        mistyped_cols: list[tuple[str, Any, Any]] | None = None,
    ):
        self.disallowed_extra_cols = disallowed_extra_cols
        self.missing_req_cols = missing_req_cols
        self.mistyped_cols = mistyped_cols
        self.msg = msg

        super().__init__(self.message)

    @property
    def message(self) -> str:
        if self.msg is not None:
            return self.msg

        msg_parts = []
        if self.disallowed_extra_cols:
            msg_parts.append(f"Disallowed extra columns: {', '.join(self.disallowed_extra_cols)}")
        if self.missing_req_cols:
            msg_parts.append(f"Missing required columns: {', '.join(self.missing_req_cols)}")
        if self.mistyped_cols:
            mistyped_strs = [f"{col} (want {want}, got {got})" for col, want, got in self.mistyped_cols]
            msg_parts.append(f"Columns with incorrect types: {', '.join(mistyped_strs)}")

        return ". ".join(msg_parts)

TableValidationError

Bases: Exception

Exception raised for table validation errors.

Source code in flexible_schema/exceptions.py 
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
class TableValidationError(Exception):
    """Exception raised for table validation errors."""

    def __init__(
        self,
        msg: str | None = None,
        *,
        nullability_none_err_cols: list[str] | None = None,
        nullability_some_err_cols: list[str] | None = None,
    ):
        self.nullability_none_err_cols = nullability_none_err_cols
        self.nullability_some_err_cols = nullability_some_err_cols
        self.msg = msg

        super().__init__(self.message)

    @property
    def message(self) -> str:
        if self.msg is not None:
            return self.msg

        msg_parts = []
        if self.nullability_none_err_cols:
            msg_parts.append(
                f"Columns that should have no nulls but do: {', '.join(self.nullability_none_err_cols)}"
            )
        if self.nullability_some_err_cols:
            msg_parts.append(
                "Columns that should have some non-nulls but don't: "
                f"{', '.join(self.nullability_some_err_cols)}"
            )
        return ". ".join(msg_parts)