From 31bf1f66a4bf20ecc0f90c366c679c70fd8b44fc Mon Sep 17 00:00:00 2001 From: Thomas Sileo Date: Sat, 16 Jul 2022 07:50:15 +0200 Subject: [PATCH] Tweak incoming activity processing --- app/incoming_activities.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/app/incoming_activities.py b/app/incoming_activities.py index 91b59f0..6a365d3 100644 --- a/app/incoming_activities.py +++ b/app/incoming_activities.py @@ -16,7 +16,7 @@ from app.database import AsyncSession from app.database import async_session from app.utils.datetime import now -_MAX_RETRIES = 5 +_MAX_RETRIES = 8 async def new_ap_incoming_activity( @@ -91,6 +91,11 @@ async def process_next_incoming_activity(db_session: AsyncSession) -> bool: ) ).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.last_try = now()