Spaces:
Sleeping
Sleeping
| import asyncio | |
| import os | |
| import json | |
| from supabase import create_client | |
| from dotenv import load_dotenv | |
| from api import perform_candidate_analysis | |
| load_dotenv() | |
| SUPABASE_URL = os.environ.get("SUPABASE_URL") | |
| SUPABASE_KEY = os.environ.get("SUPABASE_SERVICE_ROLE_KEY") or os.environ.get("SUPABASE_KEY") | |
| client = create_client(SUPABASE_URL, SUPABASE_KEY) | |
| async def verify(): | |
| res = client.table("applications").select("user_id, job_id").limit(1).execute() | |
| if not res.data: | |
| print("No apps found") | |
| return | |
| c_id = res.data[0]["user_id"] | |
| j_id = res.data[0]["job_id"] | |
| print(f"Triggering fresh analysis for {c_id} / {j_id}") | |
| await perform_candidate_analysis(c_id, j_id, force_refresh=True) | |
| print("\nChecking resulting record in DB:") | |
| final_res = client.table("applications") \ | |
| .select("match_score, skills_match, technical_skills_match, work_experience_match, education_match, certifications_match, project_match") \ | |
| .eq("user_id", c_id).eq("job_id", j_id) \ | |
| .execute() | |
| if final_res.data: | |
| print(json.dumps(final_res.data[0], indent=2)) | |
| else: | |
| print("Record not found after update") | |
| if __name__ == "__main__": | |
| asyncio.run(verify()) | |