style: Reformat files with black for Python 3.11

Author: theoddden

src/mandala/alerts.py

@@ -207,7 +207,7 @@ async def dead_zone(event: MandalaEvent, state: StateStore, redis: object) -> li
 
 async def customs_hold_vector_stall(event: MandalaEvent, state: StateStore, redis: object) -> list[MandalaEvent]:
     """Laredo Vector Stall detector: Fire alert when customs hold lands before driver reaches bridge.
-    
+
     The "Vector Stall" problem: Customs broker knows about the hold hours before the driver
     does. If the driver is still >30 minutes from the bridge, we can reroute them to a
     hold lot instead of wasting hours in the queue.
@@ -218,24 +218,24 @@ async def customs_hold_vector_stall(event: MandalaEvent, state: StateStore, redi
         EventType.CUSTOMS_INSPECTION_REQUIRED.value,
     ):
         return []
-    
+
     data = event.data if isinstance(event.data, dict) else {}
     shipment_urn = event.subject or ""
-    
+
     # Extract Laredo-specific context from Descartes normalization
     eta_to_bridge = data.get("eta_to_bridge_minutes")
     truck_location = data.get("truck_location", "unknown")
     port_of_entry = data.get("port_of_entry", "unknown")
     hold_reason = data.get("hold_reason", "unknown")
-    
+
     # Only alert if driver hasn't reached bridge yet (>30 minutes away)
     if eta_to_bridge is None or eta_to_bridge <= 30:
         return []
-    
+
     # Debounce per shipment to avoid duplicate alerts
     if not await _debounce(redis, f"vectorstall:{shipment_urn}", ttl=3600):
         return []
-    
+
     log.info(
         "customs_hold.vector_stall",
         shipment=shipment_urn,
@@ -244,7 +244,7 @@ async def customs_hold_vector_stall(event: MandalaEvent, state: StateStore, redi
         truck_location=truck_location,
         hold_reason=hold_reason,
     )
-    
+
     return [
         new_event(
             type=EventType.ALERT_CUSTOMS_HOLD_VECTOR_STALL,

src/mandala/connectors/descartes/macropoint/normalize.py

@@ -110,18 +110,21 @@ def normalize(payload: dict[str, Any]) -> list[MandalaEvent]:
             data["location"] = {"lat": float(body["Latitude"]), "lon": float(body["Longitude"])}
         if body.get("Eta") or body.get("eta"):
             data["eta"] = body.get("Eta") or body.get("eta")
-        
+
         # Laredo Vector Stall: Extract context for customs holds
         if status_str in ("CustomsHoldLanded", "CustomsDocumentationMissing", "CustomsInspectionRequired"):
-            data.update({
-                "port_of_entry": body.get("PortOfEntry") or body.get("portOfEntry") or "unknown",
-                "filing_number": body.get("FilingNumber") or body.get("filingNumber"),
-                "hold_reason": body.get("HoldReason") or body.get("holdReason") or status_str,
-                "truck_location": body.get("TruckLocation") or body.get("truckLocation") or "unknown",
-                "eta_to_bridge_minutes": body.get("EtaToBridgeMinutes") or body.get("etaToBridgeMinutes"),
-                "estimated_clearance_hours": body.get("EstimatedClearanceHours") or body.get("estimatedClearanceHours"),
-            })
-        
+            data.update(
+                {
+                    "port_of_entry": body.get("PortOfEntry") or body.get("portOfEntry") or "unknown",
+                    "filing_number": body.get("FilingNumber") or body.get("filingNumber"),
+                    "hold_reason": body.get("HoldReason") or body.get("holdReason") or status_str,
+                    "truck_location": body.get("TruckLocation") or body.get("truckLocation") or "unknown",
+                    "eta_to_bridge_minutes": body.get("EtaToBridgeMinutes") or body.get("etaToBridgeMinutes"),
+                    "estimated_clearance_hours": body.get("EstimatedClearanceHours")
+                    or body.get("estimatedClearanceHours"),
+                }
+            )
+
         events = [
             new_event(
                 type=et,

src/mandala/mcp/server.py

@@ -297,7 +297,7 @@ async def tool_inspect_dlq(limit: int = 50) -> dict[str, Any]:
 
 async def tool_get_trailer_handoff_chain(trailer_id: str) -> dict[str, Any]:
     """Return the full handoff chain for a trailer (Mexican → Drayage → US trucks).
-    
+
     Uses the graph view to query temporal HAULED edges, showing which truck
     hauled the trailer at which time. This solves the Laredo "Brokerage Fog"
     problem by linking all three tractors via the constant trailer ID.
@@ -345,7 +345,7 @@ async def tool_get_trailer_handoff_chain(trailer_id: str) -> dict[str, Any]:
 
 async def tool_get_shipment_via_trailer(trailer_id: str) -> dict[str, Any]:
     """Return the shipment currently linked to a trailer.
-    
+
     This is the inverse of the handoff chain query — useful for answering
     "which shipment is this trailer carrying right now?"
     """
@@ -366,6 +366,7 @@ async def tool_get_shipment_via_trailer(trailer_id: str) -> dict[str, Any]:
 
         # Get current truck (if any)
         from mandala.views.graph import GraphView
+
         view = GraphView(r)
         current_truck = None
         if await view._probe():
@@ -568,7 +569,10 @@ async def tool_get_bridge_capabilities() -> dict[str, Any]:
                 "name": "check_customs_status",
                 "description": "Return customs status, authority, broker, and hold reason",
             },
-            {"name": "get_trailer_handoff_chain", "description": "Return full handoff chain for a trailer (Mexican → Drayage → US trucks)"},
+            {
+                "name": "get_trailer_handoff_chain",
+                "description": "Return full handoff chain for a trailer (Mexican → Drayage → US trucks)",
+            },
             {"name": "get_shipment_via_trailer", "description": "Return shipment currently linked to a trailer"},
         ],
         "alerts_monitoring": [

src/mandala/projection.py

@@ -142,12 +142,12 @@ async def project(event: MandalaEvent, state: StateStore) -> None:
                 if k in data and data[k] is not None:
                     patch[k] = data[k]
             await state.upsert("trailer", trailer_urn, patch)
-            
+
             # Link trailer to shipment
             shipment_urn = data.get("shipment_urn")
             if shipment_urn:
                 await state.link(trailer_urn, shipment_urn)
-            
+
             # Link truck to trailer (for handoff chain tracking)
             truck_urn = subject
             if truck_urn and truck_urn.startswith("urn:mandala:truck:"):

src/mandala/views/graph.py

@@ -151,8 +151,7 @@ async def _apply_inner(self, event: MandalaEvent) -> None:
             if truck_urn and trailer_id:
                 # Update temporal edge: set end time
                 await self._query(
-                    "MATCH (t:Truck {urn: $t})-[r:HAULED]->(trl:Trailer {id: $trl}) "
-                    "SET r.end = $end_time",
+                    "MATCH (t:Truck {urn: $t})-[r:HAULED]->(trl:Trailer {id: $trl}) " "SET r.end = $end_time",
                     {"t": truck_urn, "trl": str(trailer_id), "end_time": event.time.isoformat()},
                 )
             return
@@ -163,9 +162,7 @@ async def _apply_inner(self, event: MandalaEvent) -> None:
             shipment_urn = data.get("shipment_urn")
             if trailer_id and shipment_urn:
                 await self._query(
-                    "MERGE (trl:Trailer {id: $trl}) "
-                    "MERGE (s:Shipment {urn: $s}) "
-                    "MERGE (trl)-[:CARRIES]->(s)",
+                    "MERGE (trl:Trailer {id: $trl}) " "MERGE (s:Shipment {urn: $s}) " "MERGE (trl)-[:CARRIES]->(s)",
                     {"trl": str(trailer_id), "s": shipment_urn},
                 )
             return