Spaces:
Sleeping
Sleeping
| import os, sys | |
| sys.path.insert(0, os.path.dirname(os.path.abspath(__file__))) | |
| from dotenv import load_dotenv | |
| load_dotenv(os.path.join(os.path.dirname(os.path.dirname(os.path.abspath(__file__))), '.env')) | |
| import db | |
| c = db.get_client() | |
| # Show any non-done rows | |
| res = c.table('saved_reels').select('id,url,status,source,created_at,error,attempt_count,processing_started_at,next_attempt_at').in_('status', ['pending', 'processing', *db.FAILURE_STATUSES]).order('created_at', desc=True).limit(10).execute() | |
| rows = res.data or [] | |
| print(f'Non-done rows in queue: {len(rows)}') | |
| for r in rows: | |
| url = (r['url'] or 'NO URL')[:60] | |
| err = (r.get('error') or '')[:60] | |
| src = (r.get('source') or '')[:8] | |
| attempts = r.get("attempt_count") or 0 | |
| started = r.get("processing_started_at") or "-" | |
| next_at = r.get("next_attempt_at") or "-" | |
| print(f" {r['status']:<18} | tries={attempts} | started={started} | next={next_at} | {src:<8} | {url} | err={err}") | |
| # Also show total row count | |
| total = c.table('saved_reels').select('id', count='exact').execute() | |
| print(f'Total rows: {total.count}') | |