Fix incoming activity processing
parent
aa71bd166b
commit
ea548337f4
|
@ -98,6 +98,7 @@ async def process_next_incoming_activity(db_session: AsyncSession) -> bool:
|
||||||
|
|
||||||
next_activity.tries = next_activity.tries + 1
|
next_activity.tries = next_activity.tries + 1
|
||||||
next_activity.last_try = now()
|
next_activity.last_try = now()
|
||||||
|
await db_session.commit()
|
||||||
|
|
||||||
try:
|
try:
|
||||||
# async with db_session.begin_nested():
|
# async with db_session.begin_nested():
|
||||||
|
|
Loading…
Reference in New Issue