mirror of
https://github.com/bytedance/deer-flow.git
synced 2026-05-24 17:06:00 +00:00
feat(events): summary content uses OpenAI system message format
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
@@ -263,7 +263,7 @@ class RunJournal(BaseCallbackHandler):
|
|||||||
self._put(
|
self._put(
|
||||||
event_type="summary",
|
event_type="summary",
|
||||||
category="message",
|
category="message",
|
||||||
content=data_dict.get("summary", ""),
|
content={"role": "system", "content": data_dict.get("summary", "")},
|
||||||
metadata={"replaced_count": data_dict.get("replaced_count", 0)},
|
metadata={"replaced_count": data_dict.get("replaced_count", 0)},
|
||||||
)
|
)
|
||||||
else:
|
else:
|
||||||
|
|||||||
@@ -214,6 +214,7 @@ class TestCustomEvents:
|
|||||||
messages = await store.list_messages("t1")
|
messages = await store.list_messages("t1")
|
||||||
assert len(messages) == 1
|
assert len(messages) == 1
|
||||||
assert messages[0]["event_type"] == "summary"
|
assert messages[0]["event_type"] == "summary"
|
||||||
|
assert messages[0]["content"] == {"role": "system", "content": "Context was summarized."}
|
||||||
|
|
||||||
@pytest.mark.anyio
|
@pytest.mark.anyio
|
||||||
async def test_non_summarization_custom_event(self, journal_setup):
|
async def test_non_summarization_custom_event(self, journal_setup):
|
||||||
|
|||||||
Reference in New Issue
Block a user