update

backend/app/main.py

@@ -187,28 +187,59 @@ async def get_asset_status(asset_id: int, db: Session = Depends(get_db)):
         if conn:
             try:
                 cursor = conn.cursor()
+                # First check if extracted_content column exists
                 cursor.execute("""
-                    SELECT id, name, analysis_status, analyzed_at, extracted_content
-                    FROM assets 
-                    WHERE id = %s
-                """, (asset_id,))
+                    SELECT column_name 
+                    FROM information_schema.columns 
+                    WHERE table_name='assets' AND column_name='extracted_content'
+                """)
+                has_extracted_content = cursor.fetchone() is not None
+                
+                # Build query based on column existence
+                if has_extracted_content:
+                    cursor.execute("""
+                        SELECT id, name, analysis_status, analyzed_at, extracted_content
+                        FROM assets 
+                        WHERE id = %s
+                    """, (asset_id,))
+                else:
+                    cursor.execute("""
+                        SELECT id, name, analysis_status, analyzed_at
+                        FROM assets 
+                        WHERE id = %s
+                    """, (asset_id,))
+                
                 row = cursor.fetchone()
                 cursor.close()
                 conn.close()
+                
                 if row:
-                    return {
+                    result = {
                         "asset_id": row[0],
                         "name": row[1],
                         "status": row[2] or "pending",
                         "analyzed_at": row[3].isoformat() if row[3] else None,
-                        "extracted_content": row[4] if len(row) > 4 else None  # Include extracted JSON
                     }
+                    # Add extracted_content only if column exists and value is present
+                    if has_extracted_content and len(row) > 4:
+                        result["extracted_content"] = row[4]
+                    else:
+                        result["extracted_content"] = None
+                    return result
+                else:
+                    raise HTTPException(status_code=404, detail="Asset not found")
+            except HTTPException:
+                raise
             except Exception as e:
                 if conn:
                     conn.close()
-                raise HTTPException(status_code=500, detail=str(e))
-        raise HTTPException(status_code=404, detail="Asset not found")
+                print(f"Error in get_asset_status: {e}")
+                raise HTTPException(status_code=500, detail=f"Database error: {str(e)}")
+        raise HTTPException(status_code=500, detail="Database connection failed")
+    except HTTPException:
+        raise
     except Exception as e:
+        print(f"Error in get_asset_status (outer): {e}")
         raise HTTPException(status_code=500, detail=str(e))
 
 async def analyze_asset_background(asset_id: int, file_path: str, file_type: str):