style: apply ruff format to data/ and models/ modules

These files were committed without running ruff format via uv run,
causing a version mismatch between the local venv ruff and CI's
uv-managed ruff. Running uv run ruff format resolves all 41 files.

Author: kbichave

packages/quant_pod/data/__pycache__/__init__.cpython-311.pyc

@@ -101,10 +101,7 @@ async def run(self, tick_queue: asyncio.Queue) -> None:
         self._running = True
         reconnect_wait = self._RECONNECT_BASE_SECONDS
 
-        logger.info(
-            f"[AlpacaWS] Starting stream: feed={self._feed} "
-            f"symbols={self.symbols}"
-        )
+        logger.info(f"[AlpacaWS] Starting stream: feed={self._feed} symbols={self.symbols}")
 
         while self._running:
             try:
@@ -114,8 +111,7 @@ async def run(self, tick_queue: asyncio.Queue) -> None:
                 if not self._running:
                     break
                 logger.warning(
-                    f"[AlpacaWS] Disconnected: {e} — "
-                    f"reconnecting in {reconnect_wait:.0f}s"
+                    f"[AlpacaWS] Disconnected: {e} — reconnecting in {reconnect_wait:.0f}s"
                 )
                 await asyncio.sleep(reconnect_wait)
                 reconnect_wait = min(reconnect_wait * 2, self._RECONNECT_MAX_SECONDS)
@@ -139,16 +135,22 @@ async def _connect_and_stream(self, tick_queue: asyncio.Queue) -> None:
             ping_timeout=10,
         ) as ws:
             # Auth
-            await ws.send(json.dumps({"action": "auth", "key": self._api_key, "secret": self._api_secret}))
+            await ws.send(
+                json.dumps({"action": "auth", "key": self._api_key, "secret": self._api_secret})
+            )
             auth_resp = json.loads(await ws.recv())
             self._check_auth(auth_resp)
 
             # Subscribe to trades and quotes for all symbols
-            await ws.send(json.dumps({
-                "action": "subscribe",
-                "trades": self.symbols,
-                "quotes": self.symbols,
-            }))
+            await ws.send(
+                json.dumps(
+                    {
+                        "action": "subscribe",
+                        "trades": self.symbols,
+                        "quotes": self.symbols,
+                    }
+                )
+            )
 
             logger.info(f"[AlpacaWS] Subscribed to {self.symbols}")
 
@@ -172,7 +174,7 @@ async def _connect_and_stream(self, tick_queue: asyncio.Queue) -> None:
 
     def _check_auth(self, response: list) -> None:
         """Raise if authentication failed."""
-        for msg in (response if isinstance(response, list) else [response]):
+        for msg in response if isinstance(response, list) else [response]:
             if msg.get("T") == "error":
                 raise ConnectionError(f"Alpaca auth error: {msg.get('msg')}")
             if msg.get("T") == "success" and msg.get("msg") == "authenticated":

packages/quant_pod/data/__pycache__/market_data_bus.cpython-311.pyc

@@ -125,10 +125,7 @@ def __init__(
     async def run(self, tick_queue: asyncio.Queue) -> None:
         self._running = True
         loop = asyncio.get_event_loop()
-        logger.info(
-            f"[RestPollingBus] Started: {self.symbols} "
-            f"@ {self._interval:.0f}s interval"
-        )
+        logger.info(f"[RestPollingBus] Started: {self.symbols} @ {self._interval:.0f}s interval")
 
         while self._running:
             for symbol in self.symbols:
@@ -156,14 +153,10 @@ async def run(self, tick_queue: asyncio.Queue) -> None:
                     try:
                         tick_queue.put_nowait(tick)
                     except asyncio.QueueFull:
-                        logger.warning(
-                            f"[RestPollingBus] Tick queue full — dropping {symbol}"
-                        )
+                        logger.warning(f"[RestPollingBus] Tick queue full — dropping {symbol}")
 
                 except Exception as e:
-                    logger.warning(
-                        f"[RestPollingBus] Failed to fetch {symbol}: {e}"
-                    )
+                    logger.warning(f"[RestPollingBus] Failed to fetch {symbol}: {e}")
                     await asyncio.sleep(self._error_sleep)
 
             await asyncio.sleep(self._interval)

packages/quant_pod/data/adapters/alpaca_ws.py

@@ -20,4 +20,3 @@
     "set_provider",
     "DataValidator",
 ]
-