reflect: opt-in FRESH_CONTEXT resets history before each triggered task

agentmain.py

@@ -306,6 +306,7 @@ def _hub_put(t):
             if task:
                 print(f'[Reflect] triggered: {task[:80]}')
                 if (_ln := getattr(mod, 'LLM', None)): agent.next_llm(next((i for i, b in enumerate(agent.llmclients) if not isinstance(b, dict) and b.backend.name == _ln), agent.llm_no))
+                if getattr(mod, 'FRESH_CONTEXT', False): from frontends.continue_cmd import reset_conversation; reset_conversation(agent, snapshot=False)
                 dq = agent.put_task(task, source='reflect')
                 try:
                     while 'done' not in (item := dq.get(timeout=2200)): pass

frontends/continue_cmd.py

@@ -471,13 +471,13 @@ def _snapshot_current_log(pid=None):
     return snapshot
 
 
-def reset_conversation(agent, message='🆕 已开启新对话，当前上下文已清空'):
+def reset_conversation(agent, message='🆕 已开启新对话，当前上下文已清空', snapshot=True):
     """Abort current work and clear all known frontend-visible conversation state."""
     try:
         agent.abort()
     except Exception:
         pass
-    _snapshot_current_log()
+    if snapshot: _snapshot_current_log()
     if hasattr(agent, 'history'):
         agent.history = []
     for client in _agent_clients(agent):

reflect/scheduler.py

@@ -10,6 +10,7 @@
 
 INTERVAL = 120
 ONCE = False
+FRESH_CONTEXT = True
 
 _dir = os.path.dirname(os.path.abspath(__file__))
 TASKS = os.path.join(_dir, '../sche_tasks')