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)