Skip to content

Commit 606485e

Browse files
committed
Fix deferred compaction replay
1 parent eb7c99f commit 606485e

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/agents/run.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2071,8 +2071,10 @@ async def _save_result_to_session(
20712071
response_id,
20722072
)
20732073
return
2074-
if deferred_response_id and hasattr(session, "clear_deferred_compaction_response_id"):
2075-
session.clear_deferred_compaction_response_id()
2074+
if deferred_response_id:
2075+
await session.run_compaction({"response_id": deferred_response_id})
2076+
if hasattr(session, "clear_deferred_compaction_response_id"):
2077+
session.clear_deferred_compaction_response_id()
20762078
await session.run_compaction({"response_id": response_id})
20772079

20782080
@staticmethod

0 commit comments

Comments
 (0)