#!/usr/bin/env python3
"""Manually process pending summarization jobs"""
from app import app
from models import db, SummarizationJob
from summarization_routes import process_summarization_job
from datetime import datetime, timedelta

with app.app_context():
    # Get pending jobs from last 10 minutes
    pending_jobs = SummarizationJob.query.filter(
        SummarizationJob.status == 'pending',
        SummarizationJob.created_at > datetime.utcnow() - timedelta(minutes=10)
    ).all()

    print(f"Found {len(pending_jobs)} pending job(s)\n")

    for job in pending_jobs:
        print(f"Processing: {job.original_filename}")
        print(f"  Job UUID: {job.job_uuid}")
        print(f"  File path: {job.file_path}")

        try:
            # Process synchronously for testing
            process_summarization_job(
                job.job_uuid,
                job.file_path,
                job.summary_type or 'executive',
                job.summary_length or 'medium',
                '',  # additional_instructions
                job.user_id,
                None  # document_id - will be looked up in the function
            )
            print(f"  ✅ Completed\n")
        except Exception as e:
            print(f"  ❌ Error: {e}\n")