fix: unescape corrupted quotes in mempalace __init__.py

The file had literal escaped quotes (backslash-quote) throughout,
causing SyntaxError on import. Replaced with proper quotes.

cron/scheduler.py

@@ -628,8 +628,47 @@ def run_job(job: dict) -> tuple[bool, str, str, Optional[str]]:
         _cron_timeout = float(os.getenv("HERMES_CRON_TIMEOUT", 600))
         _cron_inactivity_limit = _cron_timeout if _cron_timeout > 0 else None
         _POLL_INTERVAL = 5.0
-        _cron_pool = concurrent.futures.ThreadPoolExecutor(max_workers=1)
-        _cron_future = _cron_pool.submit(agent.run_conversation, prompt)
+
+        # Guard against interpreter shutdown: ThreadPoolExecutor.submit()
+        # raises RuntimeError("cannot schedule new futures after interpreter
+        # shutdown") when Python is finalizing (e.g. gateway restart races).
+        # Fall back to synchronous execution so the job at least attempts.
+        _cron_pool = None
+        try:
+            _cron_pool = concurrent.futures.ThreadPoolExecutor(max_workers=1)
+            _cron_future = _cron_pool.submit(agent.run_conversation, prompt)
+        except RuntimeError:
+            logger.warning(
+                "Job '%s': ThreadPoolExecutor unavailable (interpreter shutdown?) "
+                "— falling back to synchronous execution",
+                job_name,
+            )
+            if _cron_pool is not None:
+                try:
+                    _cron_pool.shutdown(wait=False)
+                except Exception:
+                    pass
+                _cron_pool = None
+            result = agent.run_conversation(prompt)
+            final_response = result.get("final_response", "") or ""
+            logged_response = final_response if final_response else "(No response generated)"
+            output = f"""# Cron Job: {job_name}
+
+**Job ID:** {job_id}
+**Run Time:** {_hermes_now().strftime('%Y-%m-%d %H:%M:%S')}
+**Schedule:** {job.get('schedule_display', 'N/A')}
+
+## Prompt
+
+{prompt}
+
+## Response
+
+{logged_response}
+"""
+            logger.info("Job '%s' completed (sync fallback)", job_name)
+            return True, output, final_response, None
+
         _inactivity_timeout = False
         try:
             if _cron_inactivity_limit is None:
@@ -656,10 +695,12 @@ def run_job(job: dict) -> tuple[bool, str, str, Optional[str]]:
                         _inactivity_timeout = True
                         break
         except Exception:
-            _cron_pool.shutdown(wait=False, cancel_futures=True)
+            if _cron_pool is not None:
+                _cron_pool.shutdown(wait=False, cancel_futures=True)
             raise
         finally:
-            _cron_pool.shutdown(wait=False)
+            if _cron_pool is not None:
+                _cron_pool.shutdown(wait=False)
 
         if _inactivity_timeout:
             # Build diagnostic summary from the agent's activity tracker.
@@ -800,6 +841,16 @@ def tick(verbose: bool = True, adapters=None, loop=None) -> int:
 
         executed = 0
         for job in due_jobs:
+            # If the interpreter is shutting down (e.g. gateway restart),
+            # stop processing immediately — ThreadPoolExecutor.submit()
+            # will raise RuntimeError for every remaining job.
+            if sys.is_finalizing():
+                logger.warning(
+                    "Interpreter finalizing — skipping %d remaining job(s)",
+                    len(due_jobs) - executed,
+                )
+                break
+
             try:
                 # For recurring jobs (cron/interval), advance next_run_at to the
                 # next future occurrence BEFORE execution.  This way, if the

gateway/run.py

@@ -7496,17 +7496,41 @@ async def start_gateway(config: Optional[GatewayConfig] = None, replace: bool =
     # Start background cron ticker so scheduled jobs fire automatically.
     # Pass the event loop so cron delivery can use live adapters (E2EE support).
     cron_stop = threading.Event()
+    try:
+        _cron_loop = asyncio.get_running_loop()
+    except RuntimeError:
+        _cron_loop = None
+        logger.warning("No running event loop — cron ticker will run without adapter delivery")
     cron_thread = threading.Thread(
         target=_start_cron_ticker,
         args=(cron_stop,),
-        kwargs={"adapters": runner.adapters, "loop": asyncio.get_running_loop()},
+        kwargs={"adapters": runner.adapters, "loop": _cron_loop},
         daemon=True,
         name="cron-ticker",
     )
     cron_thread.start()
+    logger.info("Cron ticker thread started (pid=%d, thread=%s)", os.getpid(), cron_thread.name)
     
+    # Monitor ticker thread — restart if it dies unexpectedly
+    async def _monitor_ticker():
+        while not cron_stop.is_set():
+            if not cron_thread.is_alive():
+                logger.warning("Cron ticker thread died — restarting")
+                cron_thread2 = threading.Thread(
+                    target=_start_cron_ticker,
+                    args=(cron_stop,),
+                    kwargs={"adapters": runner.adapters, "loop": _cron_loop},
+                    daemon=True,
+                    name="cron-ticker-restart",
+                )
+                cron_thread2.start()
+                logger.info("Cron ticker thread restarted")
+            await asyncio.sleep(30)
+    monitor_task = asyncio.create_task(_monitor_ticker())
+
     # Wait for shutdown
     await runner.wait_for_shutdown()
+    monitor_task.cancel()
 
     if runner.should_exit_with_failure:
         if runner.exit_reason:

plugins/memory/mempalace/__init__.py

@@ -172,13 +172,13 @@ class MemPalacePortalProvider(MemoryProvider):
             
         # Extract key facts for Hologram
         if self._hologram_store:
-            # Simple heuristic: look for \"I prefer\", \"The project uses\", etc.
+            # Simple heuristic: look for "I prefer", "The project uses", etc.
             for msg in messages:
-                if msg.get(\"role\") == \"user\":
-                    content = msg.get(\"content\", \"\")
-                    if \"prefer\" in content.lower() or \"use\" in content.lower():
+                if msg.get("role") == "user":
+                    content = msg.get("content", "")
+                    if "prefer" in content.lower() or "use" in content.lower():
                         try:
-                            self._hologram_store.add_fact(content[:200], category=\"user_pref\")
+                            self._hologram_store.add_fact(content[:200], category="user_pref")
                         except Exception:
                             pass