Itmens/lib.itmens
Itmens/lib.itmens
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 3

retry fetch post in async task

Browse source
This commit is contained in:
Your Name 2025-02-23 10:52:41 -05:00 • committed by Henri Dickson
parent 44b4521846
commit b79971f0e0
1 changed files with 13 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
takahe/ap_handlers.py
View file

@ -106,7 +106,15 @@ def post_fetched(pk, post_data):
def _post_fetched(pk, local, post_data, create: bool | None = None): def _post_fetched(pk, local, post_data, create: bool | None = None):
post: Post = Post.objects.get(pk=pk) try:
post: Post = Post.objects.get(pk=pk)
except Post.DoesNotExist:
sleep(2)
try:
post: Post = Post.objects.get(pk=pk)
except Post.DoesNotExist:
logger.error(f"Fetched post {pk} not found")
return
owner = Takahe.get_or_create_remote_apidentity(post.author) owner = Takahe.get_or_create_remote_apidentity(post.author)
if local: if local:
activate_language_for_user(owner.user) activate_language_for_user(owner.user)
@ -242,13 +250,13 @@ def identity_fetched(pk):
try: try:
identity = Identity.objects.get(pk=pk) identity = Identity.objects.get(pk=pk)
except Identity.DoesNotExist: except Identity.DoesNotExist:
logger.warning(f"Fetched identity {pk} not found") logger.error(f"Fetched identity {pk} not found")
return return
if identity.username and identity.domain: if identity.username and identity.domain:
apid = Takahe.get_or_create_remote_apidentity(identity) apid = Takahe.get_or_create_remote_apidentity(identity)
if apid: if apid:
logger.debug(f"Identity {identity} synced") logger.debug(f"Fetched identity {identity} synced")
else: else:
logger.warning(f"Identity {identity} not synced") logger.error(f"Fetched identity {identity} not synced")
else: else:
logger.warning(f"Identity {identity} has no username or domain") logger.error(f"Fetched identity {identity} has no username or domain")