forks/microblog.pub
1
0
Fork 1
mirror of https://git.sr.ht/~tsileo/microblog.pub synced 2024-11-15 03:04:28 +00:00
Code Issues Projects Releases Packages Wiki Activity

Tweak the tasks

Browse source
This commit is contained in:
Thomas Sileo 2018-08-05 14:04:09 +02:00
parent 34579bd151
commit 57c6c765b6
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
tasks.py
View file

@ -320,7 +320,10 @@ def finish_post_to_inbox(self, iri: str) -> None:
try: try:
activity = ap.fetch_remote_activity(iri) activity = ap.fetch_remote_activity(iri)
log.info(f"activity={activity!r}") log.info(f"activity={activity!r}")
except (ActivityGoneError, ActivityNotFoundError):
log.exception(f"no retry")
try:
if activity.has_type(ap.ActivityType.DELETE): if activity.has_type(ap.ActivityType.DELETE):
back.inbox_delete(MY_PERSON, activity) back.inbox_delete(MY_PERSON, activity)
elif activity.has_type(ap.ActivityType.UPDATE): elif activity.has_type(ap.ActivityType.UPDATE):
@ -343,7 +346,6 @@ def finish_post_to_inbox(self, iri: str) -> None:
back.inbox_undo_announce(MY_PERSON, obj) back.inbox_undo_announce(MY_PERSON, obj)
elif obj.has_type(ap.ActivityType.FOLLOW): elif obj.has_type(ap.ActivityType.FOLLOW):
back.undo_new_follower(MY_PERSON, obj) back.undo_new_follower(MY_PERSON, obj)
except Exception as err: except Exception as err:
log.exception(f"failed to cache attachments for {iri}") log.exception(f"failed to cache attachments for {iri}")
self.retry(exc=err, countdown=int(random.uniform(2, 4) ** self.request.retries)) self.retry(exc=err, countdown=int(random.uniform(2, 4) ** self.request.retries))
@ -368,7 +370,10 @@ def finish_post_to_outbox(self, iri: str) -> None:
try: try:
activity = ap.fetch_remote_activity(iri) activity = ap.fetch_remote_activity(iri)
log.info(f"activity={activity!r}") log.info(f"activity={activity!r}")
except (ActivityGoneError, ActivityNotFoundError):
log.exception(f"no retry")
try:
recipients = activity.recipients() recipients = activity.recipients()
if activity.has_type(ap.ActivityType.DELETE): if activity.has_type(ap.ActivityType.DELETE):