agno 如何用 continue_from 回退到歷史消息點或 fork 出新的 run 與 session【免費下載鏈接】agnoBuild, run, and manage agent platforms.項目地址: https://gitcode.com/GitHub_Trending/ag/agno如果你已經(jīng)跑完或跑掛過一個 agno Agent 的 run想在某個歷史消息位置重新接上去、或者從某個狀態(tài)分叉出一條互不影響的新對話就需要用/continue能力用continue_from指定回退到哪個消息點用forkTrue顯式 fork 出新的 sibling run或用fork_session()把整個 session 復制到一個新 session。本文基于 cookbook 中的三個可運行示例01_continue_from.py、02_fork_run.py、01_fork_session.py給出完整操作路徑。前提先讓 run 可回退/continue系列能力建立在持久化的 run 之上。按 18_checkpointing/README.md 的說明默認的checkpointruns只在終態(tài)COMPLETED、PAUSED、CANCELLED、ERROR寫庫checkpointtool-batch在每個 tool batch 之后寫一次這份中途持久化正是/continue能回退、能 fork 的基礎checkpointtools逐 tool 寫留給 3.0目前會拋NotImplementedError。所以示例中的 Agent 統(tǒng)一配置了db和checkpointtool-batch。示例使用的模型為OpenAIResponses(idgpt-5.4)運行前需要OPENAI_API_KEYTEST_LOG.md 中標注了示例依賴該 key。01 示例用本地 SQLitetmp/checkpoint_time_travel.db02 示例用 Postgresfrom agno.agent import Agent from agno.db.sqlite import SqliteDb from agno.models.openai import OpenAIResponses agent Agent( nametravel-agent, modelOpenAIResponses(idgpt-5.4), dbSqliteDb( session_tablecheckpoint_demo, db_filetmp/checkpoint_time_travel.db, ), checkpointtool-batch, tools[get_population], # 示例中的 mock 工具 )continue_from 的三種邊界寫法continue_from決定回退到哪個消息位置有三種寫法見 20_time_travel/README.md寫法語義end默認保留完整 transcript等同于普通追問last_user保留到最后一個 user 消息為止丟棄 user 之后的尾部tool 會被重新調(diào)用Kint保留messages[:K]精確的消息索引邊界無論選哪種邊界邊界都會自動吸附到 tool-call 安全索引如果截斷會把 assistant 的 tool_call 與其 result 拆散邊界會回移到該 exchange 的開頭保證恢復后的 transcript 始終合法?；赝说綒v史消息點并繼續(xù)先跑一個基礎 run拿到run_id和session_idfirst await agent.arun(inputWhat is the population of Paris?) # first.run_id / first.session_id 是后續(xù)所有 /continue 操作的定位參數(shù)然后用acontinue_run指定邊界回退并傳入新的input?；赝说阶詈笠粭l user 消息之后、換一個問題rewound await agent.acontinue_run( run_idfirst.run_id, session_idfirst.session_id, continue_fromlast_user, inputActually, what is the population of Tokyo instead?, )當end/last_user落不到你想要的位置時比如還要多丟掉一組 tool 結(jié)果用數(shù)字索引。示例中先用 1 起序號打印first.messages找出目標位置再把索引從len(run.messages)往前數(shù)出 K 傳入for i, m in enumerate(first.messages or [], start1): print(f [{i}] {m.role}: {(m.content or )[:60]}) rewound_to_index await agent.acontinue_run( run_idfirst.run_id, session_idfirst.session_id, continue_from1, # 只保留第 1 條消息原始用戶問題 inputInstead, what is the population of Tokyo?, )需要說明對COMPLETED的 run 執(zhí)行/continue會自動 fork出一個新的 sibling run保持 1 run 1 model loop 約定源 run 原樣保留。所以這里的rewound并不是在原地改寫first而是同一 session 里的一個新 run。顯式 fork 出新的 run如果對象不是 COMPLETED run例如中途被取消、還在 RUNNING想讓/continue明確創(chuàng)建 sibling 而不是原地恢復傳forkTrue。02 示例02_fork_run.py展示了從已知狀態(tài)分叉的用法——例如從同一個狀態(tài)出發(fā)跑不同 prompt 做 eval 或 A/B 對比fork await agent.acontinue_run( run_idoriginal.run_id, session_idoriginal.session_id, continue_fromlast_user, inputWhats the weather in Tokyo and Lagos?, )fork 出來的 run 帶三個可核對的字段run_id全新的 run idforked_from_run_id指向源 runforked_from_message_index截斷索引session_id與源 run 相同——fork 和源 run 共存于同一個 sessionsession 的runs數(shù)組因此形成一個 DAG每個 fork 通過forked_from_run_id指回來源。對應的服務端入口是POST /runs/{run_id}/continue見 21_fork_session/README.md 中的對照表。fork 出新的 sessionrun 級 fork 是同一個 session 內(nèi)多一條 run如果你想把整個對話復制出去、開一條完全獨立的對話線用fork_session()。它會深拷貝源 session 的每個 run生成全新的session_id和全新的run_id源 session 不受影響對應入口POST /sessions/{session_id}/forkoriginal_sid trip-planning-original user_id demo-user # 先在源 session 里積累兩輪對話 await agent.arun(inputIm planning a trip to Japan..., session_idoriginal_sid, user_iduser_id) await agent.arun(inputTell me more about Kyoto., session_idoriginal_sid, user_iduser_id) # 分叉拿到一個全新的 session_id new_sid await agent.afork_session( source_session_idoriginal_sid, user_iduser_id, )之后可以在兩個 session 中各自獨立繼續(xù)互不影響forked_run await agent.arun( inputActually, what about Osakas street food scene?, session_idnew_sid, user_iduser_id, ) original_run await agent.arun( inputWhich Kyoto temples are must-see?, session_idoriginal_sid, user_iduser_id, )兩點注意源 session 按調(diào)用方的user_id作用域讀取——你只能 fork 自己的 session血緣字段有兩層run.forked_from_session_id記錄 run 的最初源 session跨嵌套 fork 保持不變session.session_data[forked_from_session_id]記錄直接父 session每次再 fork 會被覆蓋。對 root → mid → leaf 的鏈leaf.runs[*].forked_from_session_id root而leaf.session.session_data[forked_from_session_id] mid。fork 與 fork_session 的區(qū)分forkTruerun 級fork_session()session 級粒度RunSession結(jié)果同 session 內(nèi)的新 sibling run含所有 run 副本的新 session入口POST /runs/{run_id}/continuePOST /sessions/{session_id}/fork血緣字段run.forked_from_run_idrun.forked_from_session_id驗證回退與 fork 的結(jié)果三個示例都給出了同一類核對方式直接查庫里的 session確認源 run 保留、fork 已加入。run 級01 / 02 示例末尾session agent.db.get_session(session_idfirst.session_id, session_typeagent) print(fRuns in session: {len(session.runs or [])} (source preserved, forks added)) # 02 示例進一步逐條打印每個 run 的來源 for r in session.runs or []: marker f (forked from {r.forked_from_run_id}) if r.forked_from_run_id else print(f - {r.run_id} [{r.status}]{marker})判斷依據(jù)len(session.runs)隨每次 fork 增加新 run 的forked_from_run_id非空且指向源 run源 run 的status保持原值。session 級01_fork_session.py 末尾for sid, label in [(original_sid, original), (new_sid, forked)]: s agent.db.get_session(session_idsid, session_typeagent) forked_from_session_id (s.session_data or {}).get(forked_from_session_id) print(f{label}: {sid} ({len(s.runs or [])} runs) (f forked_from_session_id{forked_from_session_id} if forked_from_session_id else ))判斷依據(jù)original 的 run 數(shù)不變、無forked_from_session_idforked session 攜帶forked_from_session_id且 run 數(shù)與源一致全部為副本。限制與相近能力continue_fromlast_user會丟掉 user 之后的整段尾部tool_calls、結(jié)果、回復tool 會被重新調(diào)用如果只想重跑最后的總結(jié)、保留工具結(jié)果用regenerateTrue——它只丟棄末尾無 tool 調(diào)用的 assistant 回合永不重調(diào) tool且總是 fork 出新 runreplace_originalFalse可讓源 run 保持可見以便對比。對照見 19_regenerate/README.md 中的比較表。數(shù)字邊界K的取值需要先發(fā)現(xiàn)合法索引直接檢查run.messages示例做法或調(diào)用 checkpoint timeline 接口參考 03_checkpoint_endpoints.py。邊界自動吸附到 tool-call 安全索引無需手工保證 K 落在安全位置?；赝?fork 依賴checkpointtool-batch提供的中途持久化它是session.runsJSON 列上的真實寫放大文檔建議用于長研究類 run而非高頻閑聊 agent。運行示例.venvs/demo/bin/python cookbook/02_agents/20_time_travel/01_continue_from.py .venvs/demo/bin/python cookbook/02_agents/20_time_travel/02_fork_run.py .venvs/demo/bin/python cookbook/02_agents/21_fork_session/01_fork_session.py需要進一步看 checkpoint 與/continue的接口細節(jié)可繼續(xù)讀 18_checkpointing/只想重做最后一條回答則看 19_regenerate/?！久赓M下載鏈接】agnoBuild, run, and manage agent platforms.項目地址: https://gitcode.com/GitHub_Trending/ag/agno創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考 agno 如何用 continue_from 回退到歷史消息點，或 fork 出新的 run 與 session？
agno 如何用 continue_from 回退到歷史消息點或 fork 出新的 run 與 session【免費下載鏈接】agnoBuild, run, and manage agent platforms.項目地址: https://gitcode.com/GitHub_Trending/ag/agno如果你已經(jīng)跑完或跑掛過一個 agno Agent 的 run想在某個歷史消息位置重新接上去、或者從某個狀態(tài)分叉出一條互不影響的新對話就需要用/continue能力用continue_from指定回退到哪個消息點用forkTrue顯式 fork 出新的 sibling run或用fork_session()把整個 session 復制到一個新 session。本文基于 cookbook 中的三個可運行示例01_continue_from.py、02_fork_run.py、01_fork_session.py給出完整操作路徑。前提先讓 run 可回退/continue系列能力建立在持久化的 run 之上。按 18_checkpointing/README.md 的說明默認的checkpointruns只在終態(tài)COMPLETED、PAUSED、CANCELLED、ERROR寫庫checkpointtool-batch在每個 tool batch 之后寫一次這份中途持久化正是/continue能回退、能 fork 的基礎checkpointtools逐 tool 寫留給 3.0目前會拋NotImplementedError。所以示例中的 Agent 統(tǒng)一配置了db和checkpointtool-batch。示例使用的模型為OpenAIResponses(idgpt-5.4)運行前需要OPENAI_API_KEYTEST_LOG.md 中標注了示例依賴該 key。01 示例用本地 SQLitetmp/checkpoint_time_travel.db02 示例用 Postgresfrom agno.agent import Agent from agno.db.sqlite import SqliteDb from agno.models.openai import OpenAIResponses agent Agent( nametravel-agent, modelOpenAIResponses(idgpt-5.4), dbSqliteDb( session_tablecheckpoint_demo, db_filetmp/checkpoint_time_travel.db, ), checkpointtool-batch, tools[get_population], # 示例中的 mock 工具 )continue_from 的三種邊界寫法continue_from決定回退到哪個消息位置有三種寫法見 20_time_travel/README.md寫法語義end默認保留完整 transcript等同于普通追問last_user保留到最后一個 user 消息為止丟棄 user 之后的尾部tool 會被重新調(diào)用Kint保留messages[:K]精確的消息索引邊界無論選哪種邊界邊界都會自動吸附到 tool-call 安全索引如果截斷會把 assistant 的 tool_call 與其 result 拆散邊界會回移到該 exchange 的開頭保證恢復后的 transcript 始終合法?；赝说綒v史消息點并繼續(xù)先跑一個基礎 run拿到run_id和session_idfirst await agent.arun(inputWhat is the population of Paris?) # first.run_id / first.session_id 是后續(xù)所有 /continue 操作的定位參數(shù)然后用acontinue_run指定邊界回退并傳入新的input?；赝说阶詈笠粭l user 消息之后、換一個問題rewound await agent.acontinue_run( run_idfirst.run_id, session_idfirst.session_id, continue_fromlast_user, inputActually, what is the population of Tokyo instead?, )當end/last_user落不到你想要的位置時比如還要多丟掉一組 tool 結(jié)果用數(shù)字索引。示例中先用 1 起序號打印first.messages找出目標位置再把索引從len(run.messages)往前數(shù)出 K 傳入for i, m in enumerate(first.messages or [], start1): print(f [{i}] {m.role}: {(m.content or )[:60]}) rewound_to_index await agent.acontinue_run( run_idfirst.run_id, session_idfirst.session_id, continue_from1, # 只保留第 1 條消息原始用戶問題 inputInstead, what is the population of Tokyo?, )需要說明對COMPLETED的 run 執(zhí)行/continue會自動 fork出一個新的 sibling run保持 1 run 1 model loop 約定源 run 原樣保留。所以這里的rewound并不是在原地改寫first而是同一 session 里的一個新 run。顯式 fork 出新的 run如果對象不是 COMPLETED run例如中途被取消、還在 RUNNING想讓/continue明確創(chuàng)建 sibling 而不是原地恢復傳forkTrue。02 示例02_fork_run.py展示了從已知狀態(tài)分叉的用法——例如從同一個狀態(tài)出發(fā)跑不同 prompt 做 eval 或 A/B 對比fork await agent.acontinue_run( run_idoriginal.run_id, session_idoriginal.session_id, continue_fromlast_user, inputWhats the weather in Tokyo and Lagos?, )fork 出來的 run 帶三個可核對的字段run_id全新的 run idforked_from_run_id指向源 runforked_from_message_index截斷索引session_id與源 run 相同——fork 和源 run 共存于同一個 sessionsession 的runs數(shù)組因此形成一個 DAG每個 fork 通過forked_from_run_id指回來源。對應的服務端入口是POST /runs/{run_id}/continue見 21_fork_session/README.md 中的對照表。fork 出新的 sessionrun 級 fork 是同一個 session 內(nèi)多一條 run如果你想把整個對話復制出去、開一條完全獨立的對話線用fork_session()。它會深拷貝源 session 的每個 run生成全新的session_id和全新的run_id源 session 不受影響對應入口POST /sessions/{session_id}/forkoriginal_sid trip-planning-original user_id demo-user # 先在源 session 里積累兩輪對話 await agent.arun(inputIm planning a trip to Japan..., session_idoriginal_sid, user_iduser_id) await agent.arun(inputTell me more about Kyoto., session_idoriginal_sid, user_iduser_id) # 分叉拿到一個全新的 session_id new_sid await agent.afork_session( source_session_idoriginal_sid, user_iduser_id, )之后可以在兩個 session 中各自獨立繼續(xù)互不影響forked_run await agent.arun( inputActually, what about Osakas street food scene?, session_idnew_sid, user_iduser_id, ) original_run await agent.arun( inputWhich Kyoto temples are must-see?, session_idoriginal_sid, user_iduser_id, )兩點注意源 session 按調(diào)用方的user_id作用域讀取——你只能 fork 自己的 session血緣字段有兩層run.forked_from_session_id記錄 run 的最初源 session跨嵌套 fork 保持不變session.session_data[forked_from_session_id]記錄直接父 session每次再 fork 會被覆蓋。對 root → mid → leaf 的鏈leaf.runs[*].forked_from_session_id root而leaf.session.session_data[forked_from_session_id] mid。fork 與 fork_session 的區(qū)分forkTruerun 級fork_session()session 級粒度RunSession結(jié)果同 session 內(nèi)的新 sibling run含所有 run 副本的新 session入口POST /runs/{run_id}/continuePOST /sessions/{session_id}/fork血緣字段run.forked_from_run_idrun.forked_from_session_id驗證回退與 fork 的結(jié)果三個示例都給出了同一類核對方式直接查庫里的 session確認源 run 保留、fork 已加入。run 級01 / 02 示例末尾session agent.db.get_session(session_idfirst.session_id, session_typeagent) print(fRuns in session: {len(session.runs or [])} (source preserved, forks added)) # 02 示例進一步逐條打印每個 run 的來源 for r in session.runs or []: marker f (forked from {r.forked_from_run_id}) if r.forked_from_run_id else print(f - {r.run_id} [{r.status}]{marker})判斷依據(jù)len(session.runs)隨每次 fork 增加新 run 的forked_from_run_id非空且指向源 run源 run 的status保持原值。session 級01_fork_session.py 末尾for sid, label in [(original_sid, original), (new_sid, forked)]: s agent.db.get_session(session_idsid, session_typeagent) forked_from_session_id (s.session_data or {}).get(forked_from_session_id) print(f{label}: {sid} ({len(s.runs or [])} runs) (f forked_from_session_id{forked_from_session_id} if forked_from_session_id else ))判斷依據(jù)original 的 run 數(shù)不變、無forked_from_session_idforked session 攜帶forked_from_session_id且 run 數(shù)與源一致全部為副本。限制與相近能力continue_fromlast_user會丟掉 user 之后的整段尾部tool_calls、結(jié)果、回復tool 會被重新調(diào)用如果只想重跑最后的總結(jié)、保留工具結(jié)果用regenerateTrue——它只丟棄末尾無 tool 調(diào)用的 assistant 回合永不重調(diào) tool且總是 fork 出新 runreplace_originalFalse可讓源 run 保持可見以便對比。對照見 19_regenerate/README.md 中的比較表。數(shù)字邊界K的取值需要先發(fā)現(xiàn)合法索引直接檢查run.messages示例做法或調(diào)用 checkpoint timeline 接口參考 03_checkpoint_endpoints.py。邊界自動吸附到 tool-call 安全索引無需手工保證 K 落在安全位置?；赝?fork 依賴checkpointtool-batch提供的中途持久化它是session.runsJSON 列上的真實寫放大文檔建議用于長研究類 run而非高頻閑聊 agent。運行示例.venvs/demo/bin/python cookbook/02_agents/20_time_travel/01_continue_from.py .venvs/demo/bin/python cookbook/02_agents/20_time_travel/02_fork_run.py .venvs/demo/bin/python cookbook/02_agents/21_fork_session/01_fork_session.py需要進一步看 checkpoint 與/continue的接口細節(jié)可繼續(xù)讀 18_checkpointing/只想重做最后一條回答則看 19_regenerate/?！久赓M下載鏈接】agnoBuild, run, and manage agent platforms.項目地址: https://gitcode.com/GitHub_Trending/ag/agno創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考