From cabd24605f83bf53d03516798ff3c26b1bafd323 Mon Sep 17 00:00:00 2001 From: zhayujie Date: Wed, 15 Apr 2026 00:33:33 +0800 Subject: [PATCH] fix: add random jitter to daily dream schedule --- bridge/agent_initializer.py | 7 +++++-- docs/skills/install.mdx | 2 +- plugins/cow_cli/cow_cli.py | 27 ++++++++++++++++++++------- 3 files changed, 26 insertions(+), 10 deletions(-) diff --git a/bridge/agent_initializer.py b/bridge/agent_initializer.py index 30b6bc64..32768d39 100644 --- a/bridge/agent_initializer.py +++ b/bridge/agent_initializer.py @@ -548,14 +548,17 @@ class AgentInitializer: import threading def _daily_flush_loop(): + import random while True: try: now = datetime.datetime.now() - target = now.replace(hour=23, minute=55, second=0, microsecond=0) + jitter_min = random.randint(50, 55) + jitter_sec = random.randint(0, 59) + target = now.replace(hour=23, minute=jitter_min, second=jitter_sec, microsecond=0) if target <= now: target += datetime.timedelta(days=1) wait_seconds = (target - now).total_seconds() - logger.info(f"[DailyFlush] Next flush at {target.strftime('%Y-%m-%d %H:%M')} (in {wait_seconds/3600:.1f}h)") + logger.info(f"[DailyFlush] Next flush at {target.strftime('%Y-%m-%d %H:%M:%S')} (in {wait_seconds/3600:.1f}h)") time.sleep(wait_seconds) self._flush_all_agents() diff --git a/docs/skills/install.mdx b/docs/skills/install.mdx index c2e633c6..dd876f15 100644 --- a/docs/skills/install.mdx +++ b/docs/skills/install.mdx @@ -34,7 +34,7 @@ CowAgent 支持通过统一的 `install` 命令安装来自 **[Cow 技能广场] ## 从 LinkAI 安装 -[LinkAI](https://link-ai.tech/console) 上的所有公开资源 (1w+个插件/应用/工作流) ，以及自己创建的资源 (应用/工作流/知识库/数据库/插件) 都可以通过命令一键安装： +[LinkAI](https://link-ai.tech/console) 上的所有公开资源 (1w+个应用/工作流/插件) ，以及自己创建的资源 (应用/工作流/知识库/数据库/插件) 都可以通过命令一键安装： ```text /skill install linkai: diff --git a/plugins/cow_cli/cow_cli.py b/plugins/cow_cli/cow_cli.py index c470529b..6f58c1be 100644 --- a/plugins/cow_cli/cow_cli.py +++ b/plugins/cow_cli/cow_cli.py @@ -174,7 +174,7 @@ class CowCliPlugin(Plugin): # status # ------------------------------------------------------------------ - def _cmd_status(self, args: str, e_context: EventContext, session_id: str = "") -> str: + def _cmd_status(self, args: str, e_context: EventContext, session_id: str = "", **_) -> str: from config import conf cfg = conf() @@ -256,7 +256,7 @@ class CowCliPlugin(Plugin): # context # ------------------------------------------------------------------ - def _cmd_context(self, args: str, e_context: EventContext, session_id: str = "") -> str: + def _cmd_context(self, args: str, e_context: EventContext, session_id: str = "", **_) -> str: session_id = self._get_session_id(e_context, fallback=session_id) agent = self._get_agent(session_id) @@ -885,7 +885,6 @@ class CowCliPlugin(Plugin): if agent and agent.memory_manager: flush_mgr = agent.memory_manager.flush_manager - # Fallback: construct a temporary MemoryFlushManager when agent is not yet initialized if not flush_mgr: try: flush_mgr = self._create_standalone_flush_manager() @@ -895,24 +894,38 @@ class CowCliPlugin(Plugin): if not flush_mgr.llm_model: return "⚠️ 未配置 LLM 模型，无法执行记忆蒸馏" + # SaaS (e_context is None): run synchronously, return full result + if e_context is None: + return self._memory_dream_sync(flush_mgr, days) + + # Local channels: run in background, notify via channel.send() is_web = self._is_web_channel(e_context) def _run(): try: result = flush_mgr.deep_dream(lookback_days=days, force=True) if result: - msg = self._build_dream_result(flush_mgr, is_web) - self._notify(e_context, msg) + self._notify(e_context, self._build_dream_result(flush_mgr, is_web)) else: self._notify(e_context, "💤 记忆蒸馏跳过 — 没有新的记忆内容需要整理") except Exception as e: logger.warning(f"[CowCli] /memory dream failed: {e}") self._notify(e_context, f"❌ 记忆蒸馏失败: {e}") - thread = threading.Thread(target=_run, daemon=True) - thread.start() + threading.Thread(target=_run, daemon=True).start() return f"🌙 记忆蒸馏已启动 (整理近 {days} 天的记忆)\n\n整理在后台执行，完成后会通知你。" + def _memory_dream_sync(self, flush_mgr, days: int) -> str: + """Run deep dream synchronously and return the full result.""" + try: + result = flush_mgr.deep_dream(lookback_days=days, force=True) + if result: + return self._build_dream_result(flush_mgr, is_web=True) + return "💤 记忆蒸馏跳过 — 没有新的记忆内容需要整理" + except Exception as e: + logger.warning(f"[CowCli] /memory dream sync failed: {e}") + return f"❌ 记忆蒸馏失败: {e}" + @staticmethod def _notify(e_context, text: str): """Push a notification message back to the chat channel."""