fix: black formatting fixed

Author: ayushkrtiwari

src/quant_research_starter/api/auth.py

@@ -95,7 +95,9 @@ async def get_current_user(
     return user
 
 
-async def require_active_user(current_user: Annotated[models.User, Depends(get_current_user)]):
+async def require_active_user(
+    current_user: Annotated[models.User, Depends(get_current_user)],
+):
     if not current_user.is_active:
         raise HTTPException(status_code=400, detail="Inactive user")
     return current_user

src/quant_research_starter/api/routers/auth.py

@@ -49,7 +49,10 @@ async def login_for_access_token(
         try:
             token_response = supabase.sign_in(form_data.username, form_data.password)
             # token_response may contain access_token and refresh_token
-            return {"access_token": token_response.get("access_token"), "token_type": "bearer"}
+            return {
+                "access_token": token_response.get("access_token"),
+                "token_type": "bearer",
+            }
         except Exception as exc:
             raise HTTPException(status_code=400, detail=str(exc)) from exc
 

src/quant_research_starter/api/supabase.py

@@ -29,7 +29,9 @@ def signup(email: str, password: str) -> dict:
     assert is_enabled(), "Supabase not configured"
     url = f"{SUPABASE_URL.rstrip('/')}/auth/v1/signup"
     headers = {"apikey": SUPABASE_ANON_KEY, "Content-Type": "application/json"}
-    resp = requests.post(url, json={"email": email, "password": password}, headers=headers)
+    resp = requests.post(
+        url, json={"email": email, "password": password}, headers=headers
+    )
     resp.raise_for_status()
     return resp.json()
 
@@ -39,7 +41,9 @@ def sign_in(email: str, password: str) -> dict:
     assert is_enabled(), "Supabase not configured"
     url = f"{SUPABASE_URL.rstrip('/')}/auth/v1/token?grant_type=password"
     headers = {"apikey": SUPABASE_ANON_KEY, "Content-Type": "application/json"}
-    resp = requests.post(url, json={"email": email, "password": password}, headers=headers)
+    resp = requests.post(
+        url, json={"email": email, "password": password}, headers=headers
+    )
     resp.raise_for_status()
     return resp.json()
 

src/quant_research_starter/api/tasks/tasks.py

@@ -25,7 +25,9 @@ def _safe_publish(channel: str, payload: str):
     try:
         redis_client.publish(channel, payload)
     except Exception:
-        logger.warning("Could not publish to Redis channel %s (connection unavailable)", channel)
+        logger.warning(
+            "Could not publish to Redis channel %s (connection unavailable)", channel
+        )
 
 
 @celery_app.task(bind=True, name="quant_research_starter.api.tasks.tasks.run_backtest")

tests/test_factors.py

@@ -69,19 +69,19 @@ def test_momentum_values(self):
         lb = getattr(momentum, "lookback", 5)
 
         # Ensure there is enough data for the expected calculation
-        assert len(prices) > (skip + lb), (
-            "test setup doesn't have enough data for momentum calculation"
-        )
+        assert len(prices) > (
+            skip + lb
+        ), "test setup doesn't have enough data for momentum calculation"
 
         expected_momentum = (
             prices.shift(skip).iloc[-1, 0] / prices.shift(skip + lb).iloc[-1, 0]
         ) - 1
         actual = result.iloc[-1, 0]
 
         assert np.isfinite(actual), f"momentum result is not finite: {actual}"
-        assert np.isclose(actual, expected_momentum, atol=1e-6), (
-            f"momentum mismatch: got {actual}, expected {expected_momentum}"
-        )
+        assert np.isclose(
+            actual, expected_momentum, atol=1e-6
+        ), f"momentum mismatch: got {actual}, expected {expected_momentum}"
 
 
 class TestValueFactor:
@@ -168,9 +168,9 @@ def test_volatility_calculation(self):
 
         # Allow NaNs during rolling warm-up; only validate values after the lookback window is available.
         post_warmup = result.iloc[lookback:].values.flatten()
-        assert np.all(np.isfinite(post_warmup)), (
-            "volatility results contain non-finite values after warm-up"
-        )
+        assert np.all(
+            np.isfinite(post_warmup)
+        ), "volatility results contain non-finite values after warm-up"
 
         # Compute realized rolling volatility (std of pct-change) over the lookback window for each series
         realized = (
@@ -179,23 +179,23 @@ def test_volatility_calculation(self):
         factor_last = result.iloc[-1]  # Series: index=columns
 
         # Sanity: realized vol should be finite and non-equal
-        assert np.all(np.isfinite(realized)), (
-            "realized volatility contains non-finite values"
-        )
-        assert not np.allclose(realized.values, realized.values[0]), (
-            "realized vols are identical; test input invalid"
-        )
+        assert np.all(
+            np.isfinite(realized)
+        ), "realized volatility contains non-finite values"
+        assert not np.allclose(
+            realized.values, realized.values[0]
+        ), "realized vols are identical; test input invalid"
 
         # Use Spearman rank correlation to check monotonic relation between factor and realized vol.
         # We expect a negative correlation: higher factor -> lower realized vol (i.e., factor encodes low-vol signal).
         spearman_corr = factor_last.corr(realized, method="spearman")
 
-        assert np.isfinite(spearman_corr), (
-            f"spearman corr is not finite: {spearman_corr}"
-        )
-        assert spearman_corr < -0.5, (
-            f"volatility factor should be negatively correlated with realized volatility (spearman={spearman_corr})"
-        )
+        assert np.isfinite(
+            spearman_corr
+        ), f"spearman corr is not finite: {spearman_corr}"
+        assert (
+            spearman_corr < -0.5
+        ), f"volatility factor should be negatively correlated with realized volatility (spearman={spearman_corr})"
 
 
 class TestBollingerBandsFactor: