diff --git a/unwind/imdb.py b/unwind/imdb.py index 666f8ed..5159fa9 100644 --- a/unwind/imdb.py +++ b/unwind/imdb.py @@ -44,13 +44,17 @@ async def refresh_user_ratings_from_imdb(stop_on_dupe=True): log.info("⚡️ Loading data for %s ...", user.name) - async for rating, is_updated in load_ratings(user.imdb_id): - assert rating.user.id == user.id + try: + async for rating, is_updated in load_ratings(user.imdb_id): + assert rating.user.id == user.id - if stop_on_dupe and not is_updated: - break + if stop_on_dupe and not is_updated: + break - yield rating + yield rating + + except BaseException as err: + log.error("❌ Could not load rating for %s!", user.name, exc_info=err) def user_ratings_url(user_id):