run linters

Author: erinmikailstaples

python/rag/healthcare-support-portal/packages/auth/src/auth_service/routers/auth.py

@@ -66,7 +66,9 @@ async def register(
             detail="Only administrators can create new users. Use POST /api/v1/users/ endpoint instead.",
         )
     # Check if user already exists
-    existing_user = db.query(User).filter((User.username == user_data.username) | (User.email == user_data.email)).first()
+    existing_user = (
+        db.query(User).filter((User.username == user_data.username) | (User.email == user_data.email)).first()
+    )
 
     if existing_user:
         raise HTTPException(

python/rag/healthcare-support-portal/packages/auth/src/auth_service/routers/users.py

@@ -130,7 +130,9 @@ async def create_user(
         )
 
     # Check if user already exists
-    existing_user = db.query(User).filter((User.username == user_data.username) | (User.email == user_data.email)).first()
+    existing_user = (
+        db.query(User).filter((User.username == user_data.username) | (User.email == user_data.email)).first()
+    )
 
     if existing_user:
         raise HTTPException(

python/rag/healthcare-support-portal/packages/common/src/common/migration_check.py

@@ -20,7 +20,9 @@ def get_alembic_config() -> Config:
     alembic_ini = common_dir / "alembic.ini"
 
     if not alembic_ini.exists():
-        raise FileNotFoundError(f"alembic.ini not found at {alembic_ini}. " "Please ensure Alembic is properly initialized.")
+        raise FileNotFoundError(
+            f"alembic.ini not found at {alembic_ini}. " "Please ensure Alembic is properly initialized."
+        )
 
     config = Config(str(alembic_ini))
 

python/rag/healthcare-support-portal/packages/common/src/common/seed_data.py

@@ -197,9 +197,13 @@ def seed_patients(db: Session, users: dict[str, User], admin_token: str) -> list
 
     for patient_data in demo_patients:
         # Check if patient already exists
-        existing_patient = db.query(Patient).filter(Patient.medical_record_number == patient_data["medical_record_number"]).first()
+        existing_patient = (
+            db.query(Patient).filter(Patient.medical_record_number == patient_data["medical_record_number"]).first()
+        )
         if existing_patient:
-            print(f"✅ Patient '{patient_data['name']}' (MRN: {patient_data['medical_record_number']}) already exists, skipping")
+            print(
+                f"✅ Patient '{patient_data['name']}' (MRN: {patient_data['medical_record_number']}) already exists, skipping"
+            )
             created_patients.append(existing_patient)
 
             # Sync OSO facts for existing patients (in case they weren't synced before)
@@ -229,7 +233,9 @@ def seed_patients(db: Session, users: dict[str, User], admin_token: str) -> list
                 # Get patient from database
                 new_patient = db.query(Patient).filter(Patient.id == patient_response["id"]).first()
                 created_patients.append(new_patient)
-                print(f"✅ Created patient via API (with OSO facts): {patient_data['name']} (MRN: {patient_data['medical_record_number']})")
+                print(
+                    f"✅ Created patient via API (with OSO facts): {patient_data['name']} (MRN: {patient_data['medical_record_number']})"
+                )
             else:
                 print(f"⚠️  Failed to create patient {patient_data['name']}: {response.text}")
 

python/rag/healthcare-support-portal/packages/patient/src/patient_service/routers/patients.py

@@ -81,7 +81,9 @@ async def create_patient(
     Create a new patient
     """
     # Check if medical record number already exists
-    existing_patient = db.query(Patient).filter(Patient.medical_record_number == patient_data.medical_record_number).first()
+    existing_patient = (
+        db.query(Patient).filter(Patient.medical_record_number == patient_data.medical_record_number).first()
+    )
 
     if existing_patient:
         raise HTTPException(

python/rag/healthcare-support-portal/packages/rag/src/rag_service/main.py

@@ -64,7 +64,9 @@ async def startup_event():
         # Verify database migrations are current
         require_migrations_current()
 
-        logger.info(f"🚀 {settings.app_name} started successfully", port=settings.port, galileo_enabled=settings.galileo_enabled)
+        logger.info(
+            f"🚀 {settings.app_name} started successfully", port=settings.port, galileo_enabled=settings.galileo_enabled
+        )
 
     except Exception as e:
         logger.error(f"Failed to start {settings.app_name}", error=str(e))
@@ -73,7 +75,12 @@ async def startup_event():
 
 @app.get("/")
 async def root():
-    return {"service": "rag_service", "status": "healthy", "version": "0.1.0", "observability": {"galileo_enabled": settings.galileo_enabled}}
+    return {
+        "service": "rag_service",
+        "status": "healthy",
+        "version": "0.1.0",
+        "observability": {"galileo_enabled": settings.galileo_enabled},
+    }
 
 
 @app.get("/health")
@@ -85,7 +92,11 @@ async def health_check():
 async def observability_status():
     """Get observability configuration status"""
     return {
-        "galileo": {"enabled": settings.galileo_enabled, "project": settings.galileo_project_name, "environment": settings.galileo_environment},
+        "galileo": {
+            "enabled": settings.galileo_enabled,
+            "project": settings.galileo_project_name,
+            "environment": settings.galileo_environment,
+        },
         "logging": {"level": settings.log_level, "format": settings.log_format},
     }