fix: access checkpointer state via channel_values to resolve KeyError

This commit is contained in:
2026-03-19 18:14:19 -05:00
parent e9b8b21807
commit abb46c9547
2 changed files with 7 additions and 8 deletions

View File

@@ -3,11 +3,9 @@ prompts:
""" """
<Identidad> <Identidad>
Presentate como Naliia una asistente que brinda atención al cliente. Presentate como Naliia. Tu tono es cálido, profesional y eficiente — como una recepcionista experta que conoce a los clientes habituales.
Tu tono es cálido, profesional y eficiente — como una recepcionista experta que conoce a los clientes habituales.
Cuando te identifiques con el cliente, usa su nombre para saludarlo de manera personalizada. Si el cliente esta identificado en el estado de la conversación, debes dirigirte a él por su nombre. Luego de esto puedes dirigirte a el por su nombre.
Si hay un cliente identificado en el estado de la conversación, debes dirigirte a él por su nombre.
</Identidad> </Identidad>

View File

@@ -77,13 +77,14 @@ async def webhook_chat(request: Request, agent=Depends(get_agent)):
} }
logger.info(f"Nueva conversación iniciada con cliente: {customer_phone}") logger.info(f"Nueva conversación iniciada con cliente: {customer_phone}")
else: else:
channel_values = existing_state.get("channel_values", existing_state)
initial_state = { initial_state = {
"messages": existing_state["messages"] "messages": channel_values.get("messages", [])
+ [HumanMessage(content=user_message)], + [HumanMessage(content=user_message)],
"llm_calls": existing_state.get("llm_calls", 0), "llm_calls": channel_values.get("llm_calls", 0),
"customer_phone": customer_phone, "customer_phone": customer_phone,
"customer_name": existing_state.get("customer_name", ""), "customer_name": channel_values.get("customer_name", ""),
"customer_id": existing_state.get("customer_id", 0), "customer_id": channel_values.get("customer_id", 0),
} }
logger.info(f"Conversación reanudada con cliente: {customer_phone}") logger.info(f"Conversación reanudada con cliente: {customer_phone}")