fix/no commit db
This commit is contained in:
parent
9d0bca641b
commit
fe09de3cd8
1 changed files with 3 additions and 1 deletions
|
@ -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)
|
||||
|
|
Loading…
Reference in a new issue