Skip to content

Commit

Permalink
chore: Re-arrange operations on dialog entries
Browse files Browse the repository at this point in the history
  • Loading branch information
whiterabbit1983 committed Jun 8, 2024
1 parent ddbf7d0 commit 8fc6ad6
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions agents-api/agents_api/activities/summarization.py
Original file line number Diff line number Diff line change
Expand Up @@ -174,13 +174,11 @@ async def summarization(session_id: str) -> None:

assert len(entries) > 0, "no need to summarize on empty entries list"

trimmed_messages, entities = await asyncio.gather(
trim_messages(entries, model=summarization_model_name),
summarized, entities = await asyncio.gather(
summarize_messages(entries, model=summarization_model_name),
get_entities(entries, model=summarization_model_name),
)
summarized = await summarize_messages(
trimmed_messages, model=summarization_model_name
)
trimmed_messages = await trim_messages(summarized, model=summarization_model_name)
ts_delta = (entries[1]["timestamp"] - entries[0]["timestamp"]) / 2
new_entities_entry = Entry(
session_id=session_id,
Expand All @@ -197,13 +195,13 @@ async def summarization(session_id: str) -> None:
old_entry_ids=entities_entry_ids,
)

for msg in summarized:
for trimmed_msg, msg in zip(trimmed_messages, summarized):
new_entry = Entry(
session_id=session_id,
source="summarizer",
role="system",
name="information",
content=msg["content"],
content=trimmed_msg["content"],
timestamp=entries[-1]["timestamp"] + 0.01,
)

Expand Down

0 comments on commit 8fc6ad6

Please sign in to comment.