import sqlite3
import sys

DB_PATH = "/data/connector_queue.db"

def kill_pending_jobs():
    """Sets the status of stuck jobs to FAILED."""
    try:
        conn = sqlite3.connect(DB_PATH)
        cursor = conn.cursor()
        
        query = """
            UPDATE jobs 
            SET status = 'FAILED', error_msg = 'Manually failed by admin to clear queue.' 
            WHERE status = 'PROCESSING' OR status = 'PENDING'
        """
        
        cursor.execute(query)
        changes = conn.total_changes
        conn.commit()
        conn.close()
        
        print(f"OK: Successfully marked {changes} jobs as FAILED.")
        return 0

    except sqlite3.Error as e:
        print(f"ERROR: Could not update jobs. Reason: {e}")
        return 1

if __name__ == "__main__":
    sys.exit(kill_pending_jobs())