worker test

services/api_key_manager.py

@@ -77,9 +77,9 @@ async def get_least_used_key(db: AsyncSession) -> Tuple[int, str]:
                 selected_index = i
         else:
             # Key not in DB yet - create it and use it (0 requests)
+            # Note: Don't commit here - caller handles transaction
             new_usage = ApiKeyUsage(key_index=i, total_requests=0, success_count=0, failure_count=0)
             db.add(new_usage)
-            await db.commit()
             selected_index = i
             break
     
@@ -116,7 +116,7 @@ async def record_usage(db: AsyncSession, key_index: int, success: bool, error_me
             usage.last_error = error_message[:1000]  # Truncate to 1000 chars
     usage.last_used_at = datetime.utcnow()
     
-    await db.commit()
+    # Note: Don't commit here - caller handles transaction atomically
     logger.debug(f"Recorded {'success' if success else 'failure'} for key index {key_index}")