diff --git a/tasks.py b/tasks.py index 866769d..c6f3009 100644 --- a/tasks.py +++ b/tasks.py @@ -202,6 +202,7 @@ def scheduled_task_sync_wx_info(self, redis_config, kafka_config, gewe_config): def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, gewe_config): async def task(): try: + logger.info('定时群成员定时添好友任务开始') redis_service = RedisService() await redis_service.init(**redis_config) gewe_service = await GeWeService.get_instance(redis_service,gewe_config['api_url'])