diff --git a/jarvis_tasks/__init__.py b/jarvis_tasks/__init__.py index fd8af15..7744455 100644 --- a/jarvis_tasks/__init__.py +++ b/jarvis_tasks/__init__.py @@ -46,7 +46,7 @@ async def _start(config: Optional[str] = "config.yaml") -> None: ban.unban, lock.unlock, lockdown.lift, - reddit.stream, + reddit.reddit, reminder.remind, twitter.twitter, warning.unwarn, diff --git a/jarvis_tasks/tasks/reddit.py b/jarvis_tasks/tasks/reddit.py index 37e8681..c301235 100644 --- a/jarvis_tasks/tasks/reddit.py +++ b/jarvis_tasks/tasks/reddit.py @@ -147,7 +147,7 @@ async def _stream(sub: Sub, bot: Snake) -> None: running.remove(sub.display_name) -async def stream(bot: Snake) -> None: +async def reddit(bot: Snake) -> None: """ Sync Reddit posts in the background. @@ -158,8 +158,8 @@ async def stream(bot: Snake) -> None: if not config.reddit: logger.warn("Missing Reddit config, not starting") return - logger.debug("Starting Task-stream") - reddit = Reddit(**config.reddit) + logger.debug("Starting Task-reddit") + red = Reddit(**config.reddit) while True: subs = Subreddit.find(q(display_name__nin=running)) @@ -179,7 +179,7 @@ async def stream(bot: Snake) -> None: # Get subreddit try: - sub = await reddit.subreddit(sub.display_name) + sub = await red.subreddit(sub.display_name) except (NotFound, Forbidden) as e: # Subreddit is either quarantined, deleted, or private logger.warn(f"Subreddit {sub.display_name} raised {e.__class__.__name__}, removing") diff --git a/jarvis_tasks/tasks/twitter.py b/jarvis_tasks/tasks/twitter.py index ff3c295..9d6c248 100644 --- a/jarvis_tasks/tasks/twitter.py +++ b/jarvis_tasks/tasks/twitter.py @@ -85,6 +85,7 @@ async def twitter(bot: Snake) -> None: if not config.twitter: logger.warn("Missing Twitter config, not starting") return + logger.debug("Starting Task-twitter") auth = tweepy.AppAuthHandler(config.twitter["consumer_key"], config.twitter["consumer_secret"]) api = tweepy.API(auth) while True: