fix: use build in exceptions class

Author: rustyconover

requirements-dev.lock

@@ -86,7 +86,7 @@ python-levenshtein==0.27.1
     # via query-farm-flight-server
 query-farm-duckdb-json-serialization==0.1.2
     # via query-farm-airport-test-server
-query-farm-flight-server==0.1.10
+query-farm-flight-server==0.1.12
     # via query-farm-airport-test-server
 rapidfuzz==3.13.0
     # via levenshtein

requirements.lock

@@ -54,7 +54,7 @@ python-levenshtein==0.27.1
     # via query-farm-flight-server
 query-farm-duckdb-json-serialization==0.1.2
     # via query-farm-airport-test-server
-query-farm-flight-server==0.1.8
+query-farm-flight-server==0.1.11
     # via query-farm-airport-test-server
 rapidfuzz==3.13.0
     # via levenshtein

src/query_farm_airport_test_server/server.py

@@ -14,6 +14,7 @@
 import query_farm_flight_server.auth as auth
 import query_farm_flight_server.auth_manager as auth_manager
 import query_farm_flight_server.auth_manager_naive as auth_manager_naive
+import query_farm_flight_server.exceptions as exceptions
 import query_farm_flight_server.flight_handling as flight_handling
 import query_farm_flight_server.flight_inventory as flight_inventory
 import query_farm_flight_server.middleware as base_middleware
@@ -669,28 +670,12 @@ def exchange_insert(
                         duplicates_struct = pc.filter(value_counts, pc.greater(value_counts.field("counts"), 1))
                         duplicates = duplicates_struct.field("values")
                         if len(duplicates) > 0:
-                            raise flight.FlightServerError(
-                                f"Cannot insert rows with duplicate values in primary key column {column_name}: {duplicates}",
-                                extra_info=msgpack.packb(
-                                    {
-                                        "exception_type": "ConstraintException",
-                                        "message": f"""Duplicate key "{column_name}: {duplicates[0]}" violates primary key constraint.""",
-                                    }
-                                ),
-                            )
+                            raise exceptions.ConstraintException(column_name, duplicates)
 
                         already_exists = pc.is_in(insert_values, value_set=existing_table.column(column_name))
                         existing_rows = pc.filter(insert_values, already_exists)
                         if len(existing_rows) > 0:
-                            raise flight.FlightServerError(
-                                f"Cannot insert rows with duplicate values in primary key column {column_name}: {duplicates}",
-                                extra_info=msgpack.packb(
-                                    {
-                                        "exception_type": "ConstraintException",
-                                        "message": f"""Duplicate key "{column_name}: {existing_rows[0]}" violates primary key constraint.""",
-                                    }
-                                ),
-                            )
+                            raise exceptions.ConstraintException(column_name, existing_rows[0])
 
                     assert new_rows.num_rows > 0