diff --git a/cron/scheduler.py b/cron/scheduler.py index c80122ce8..51d7db430 100644 --- a/cron/scheduler.py +++ b/cron/scheduler.py @@ -156,6 +156,15 @@ def run_job(job: dict) -> tuple[bool, str, str, Optional[str]]: """ from run_agent import AIAgent + # Initialize SQLite session store so cron job messages are persisted + # and discoverable via session_search (same pattern as gateway/run.py). + _session_db = None + try: + from hermes_state import SessionDB + _session_db = SessionDB() + except Exception as e: + logger.debug("Job '%s': SQLite session store not available: %s", job.get("id", "?"), e) + job_id = job["id"] job_name = job["name"] prompt = job["prompt"] @@ -260,7 +269,8 @@ def run_job(job: dict) -> tuple[bool, str, str, Optional[str]]: providers_order=pr.get("order"), provider_sort=pr.get("sort"), quiet_mode=True, - session_id=f"cron_{job_id}_{_hermes_now().strftime('%Y%m%d_%H%M%S')}" + session_id=f"cron_{job_id}_{_hermes_now().strftime('%Y%m%d_%H%M%S')}", + session_db=_session_db, ) result = agent.run_conversation(prompt)