fix: use async aget method for AsyncPostgresSaver checkpointer
This commit is contained in:
@@ -70,7 +70,7 @@ async def webhook_chat(request: Request, agent=Depends(get_agent)):
|
|||||||
"customer_phone": "",
|
"customer_phone": "",
|
||||||
}
|
}
|
||||||
|
|
||||||
existing_state = await agent.checkpointer.get(config)
|
existing_state = await agent.checkpointer.aget(config)
|
||||||
if existing_state is None:
|
if existing_state is None:
|
||||||
initial_state["customer_phone"] = customer_phone
|
initial_state["customer_phone"] = customer_phone
|
||||||
logger.info(f"Nueva conversación iniciada con cliente: {customer_phone}")
|
logger.info(f"Nueva conversación iniciada con cliente: {customer_phone}")
|
||||||
|
|||||||
Reference in New Issue
Block a user