o P=Ki@shddlmZddlmZddlZddlZddlmZmZm Z e e Z ddZ ejdd d d d ZdS)) celery_app)DB_PATHN)datetime timedeltatimezonec Cs"ttjt|d}td|dz]t t M}| }| d|f| d}|dkrZ| d|f|td|d|d krYtd | d td ntd |WdWS1slwYWdSty}ztjd|ddWYd}~dSd}~ww)z. Core logic for cleaning stale deals. )hoursz5Janitor: Starting cleanup. Deleting deals older than z...z2SELECT COUNT(*) FROM deals WHERE last_seen_utc < ?rz)DELETE FROM deals WHERE last_seen_utc < ?zJanitor: Successfully deleted z stale deals.iz.Janitor: Performing VACUUM to reclaim space...VACUUMzJanitor: VACUUM complete.zJanitor: No stale deals found.NzJanitor failed: T)exc_info)rnowrutcr isoformatloggerinfosqlite3connectrcursorexecutefetchonecommit Exceptionerror)grace_period_hours cutoff_timeconnrto_delete_counter./var/www/agentarbitrage/keepa_deals/janitor.py_clean_stale_deals_logic s0      (rz%keepa_deals.janitor.clean_stale_deals)nameHcCst|S)z Deletes deals that haven't been seen/updated for a specified period (default 72 hours). This helps keep the database size manageable and removes "dead" deals that are no longer appearing in Keepa results. )r)rrrrclean_stale_deals+sr")r!)workerrcelerydb_utilsrrloggingrrr getLogger__name__rrtaskr"rrrrs   "