From fe09de3cd88fe17189c70a6b9d1a94a609d92ce6 Mon Sep 17 00:00:00 2001 From: southfox Date: Tue, 21 Mar 2023 09:32:26 +0800 Subject: [PATCH] fix/no commit db --- app/boxes.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/app/boxes.py b/app/boxes.py index c432a96..449e82a 100644 --- a/app/boxes.py +++ b/app/boxes.py @@ -54,7 +54,9 @@ async def save_incoming( ap_object=payload, ) - if process_incoming(db_session, payload): + if await process_incoming(db_session, payload): + await db_session.commit() + await db_session.flush() return incoming_activity db_session.add(incoming_activity)