Remove messages
Remove messages
This commit is contained in:
parent
257d50a584
commit
86258efcbd
@ -389,17 +389,6 @@ class WorkflowAgent(BaseAgent):
|
|||||||
session_id = state.get("session_id", "")
|
session_id = state.get("session_id", "")
|
||||||
conversation_history = state.get("conversation_history", [])
|
conversation_history = state.get("conversation_history", [])
|
||||||
|
|
||||||
# Add a message indicating the delay
|
|
||||||
delay_message = f"Aguardando {delay_value} {delay_unit}..."
|
|
||||||
if delay_description:
|
|
||||||
delay_message += f" ({delay_description})"
|
|
||||||
|
|
||||||
new_event = Event(
|
|
||||||
author=label,
|
|
||||||
content=Content(parts=[Part(text=delay_message)]),
|
|
||||||
)
|
|
||||||
content = content + [new_event]
|
|
||||||
|
|
||||||
# Store node output information
|
# Store node output information
|
||||||
node_outputs = state.get("node_outputs", {})
|
node_outputs = state.get("node_outputs", {})
|
||||||
node_outputs[node_id] = {
|
node_outputs[node_id] = {
|
||||||
@ -413,13 +402,6 @@ class WorkflowAgent(BaseAgent):
|
|||||||
import asyncio
|
import asyncio
|
||||||
await asyncio.sleep(delay_seconds)
|
await asyncio.sleep(delay_seconds)
|
||||||
|
|
||||||
# Add completion message
|
|
||||||
complete_message = f"Delay de {delay_value} {delay_unit} concluído."
|
|
||||||
complete_event = Event(
|
|
||||||
author=label,
|
|
||||||
content=Content(parts=[Part(text=complete_message)]),
|
|
||||||
)
|
|
||||||
content = content + [complete_event]
|
|
||||||
|
|
||||||
# Update node outputs with completion information
|
# Update node outputs with completion information
|
||||||
node_outputs[node_id]["delay_end_time"] = datetime.now().isoformat()
|
node_outputs[node_id]["delay_end_time"] = datetime.now().isoformat()
|
||||||
|
Loading…
Reference in New Issue
Block a user