diff --git a/resolvers/author.py b/resolvers/author.py index 743a7aac..771e3de9 100644 --- a/resolvers/author.py +++ b/resolvers/author.py @@ -192,7 +192,7 @@ async def get_author_follows(_, _info, slug="", user=None, author_id=0): logger.debug(f"getting {author_id} follows authors") cached = await redis.execute("GET", rkey) if not cached: - authors = author_follows_authors(author_id) # type: ignore + authors = author_follows_authors(author_id) # type: ignore prepared = [author.dict() for author in authors] await redis.execute( "SET", rkey, json.dumps(prepared, cls=CustomJSONEncoder) @@ -205,7 +205,7 @@ async def get_author_follows(_, _info, slug="", user=None, author_id=0): if cached and isinstance(cached, str): topics = json.loads(cached) if not cached: - topics = author_follows_topics(author_id) # type: ignore + topics = author_follows_topics(author_id) # type: ignore prepared = [topic.dict() for topic in topics] await redis.execute( "SET", rkey, json.dumps(prepared, cls=CustomJSONEncoder) diff --git a/resolvers/follower.py b/resolvers/follower.py index c826e4e4..18b69026 100644 --- a/resolvers/follower.py +++ b/resolvers/follower.py @@ -61,7 +61,7 @@ async def follow(_, info, what, slug): if isinstance(author_dict, dict): author_id = author_dict.get("id") if author_id: - follows_ids = [a.get('id') for a in follows] + follows_ids = [a.get("id") for a in follows] if author_id not in follows_ids: await cache_author(follower_dict) await notify_follower(follower_dict, author_id, "follow") diff --git a/services/cache.py b/services/cache.py index 710a7c60..fd1f3bd8 100644 --- a/services/cache.py +++ b/services/cache.py @@ -149,7 +149,8 @@ async def cache_topic(topic_dict: dict): # topic not found in the list, so add the new topic with the updated stat field follower_follows_topics.append(topic_dict) - await redis.execute('SET', + await redis.execute( + "SET", "SET", f"author:{follower_id}:follows-topics", json.dumps(follower_follows_topics), diff --git a/services/triggers.py b/services/triggers.py index 70e0c353..e7c27039 100644 --- a/services/triggers.py +++ b/services/triggers.py @@ -116,28 +116,28 @@ def after_author_update(_mapper, _connection, author: Author): def after_topic_follower_insert(_mapper, _connection, target: TopicFollower): logger.info(target) asyncio.create_task( - handle_topic_follower_change(target.topic, target.follower, True) # type: ignore + handle_topic_follower_change(target.topic, target.follower, True) # type: ignore ) def after_topic_follower_delete(_mapper, _connection, target: TopicFollower): logger.info(target) asyncio.create_task( - handle_topic_follower_change(target.topic, target.follower, False) # type: ignore + handle_topic_follower_change(target.topic, target.follower, False) # type: ignore ) def after_author_follower_insert(_mapper, _connection, target: AuthorFollower): logger.info(target) asyncio.create_task( - handle_author_follower_change(target.author, target.follower, True) # type: ignore + handle_author_follower_change(target.author, target.follower, True) # type: ignore ) def after_author_follower_delete(_mapper, _connection, target: AuthorFollower): logger.info(target) asyncio.create_task( - handle_author_follower_change(target.author, target.follower, False) # type: ignore + handle_author_follower_change(target.author, target.follower, False) # type: ignore )