zaklaus
/
microblog
1
0
Fork 0
Code Issues Pull Requests Releases Activity

Tweak incoming activity processing

main
Thomas Sileo 2022-07-16 07:50:15 +02:00
parent 1197f132ce
commit 31bf1f66a4
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/incoming_activities.py
View File

@ -16,7 +16,7 @@ from app.database import AsyncSession
from app.database import async_session from app.database import async_session
from app.utils.datetime import now from app.utils.datetime import now
_MAX_RETRIES = 5 _MAX_RETRIES = 8
async def new_ap_incoming_activity( async def new_ap_incoming_activity(
@ -91,6 +91,11 @@ async def process_next_incoming_activity(db_session: AsyncSession) -> bool:
) )
).scalar_one() ).scalar_one()
logger.info(
f"incoming_activity={next_activity.ap_object}/"
f"{next_activity.sent_by_ap_actor_id}"
)
next_activity.tries = next_activity.tries + 1 next_activity.tries = next_activity.tries + 1
next_activity.last_try = now() next_activity.last_try = now()