diff options
| author | Rapptz <[email protected]> | 2020-04-06 05:22:57 -0400 |
|---|---|---|
| committer | Rapptz <[email protected]> | 2020-04-06 05:22:57 -0400 |
| commit | 8874aa3dd2cbc2afd7fbb583ee98b5406dc40ec0 (patch) | |
| tree | 1b25924de9590cfed043800ba26a458e047b9fe5 | |
| parent | Bump version for development (diff) | |
| download | discord.py-8874aa3dd2cbc2afd7fbb583ee98b5406dc40ec0.tar.xz discord.py-8874aa3dd2cbc2afd7fbb583ee98b5406dc40ec0.zip | |
Move log levels around to make INFO a little less noisy
| -rw-r--r-- | discord/gateway.py | 6 | ||||
| -rw-r--r-- | discord/state.py | 10 |
2 files changed, 10 insertions, 6 deletions
diff --git a/discord/gateway.py b/discord/gateway.py index 5611e732..439cdfa8 100644 --- a/discord/gateway.py +++ b/discord/gateway.py @@ -245,7 +245,7 @@ class DiscordWebSocket(websockets.client.WebSocketClientProtocol): client._connection._update_references(ws) - log.info('Created websocket connected to %s', gateway) + log.debug('Created websocket connected to %s', gateway) # poll event for OP Hello await ws.poll_event() @@ -259,7 +259,7 @@ class DiscordWebSocket(websockets.client.WebSocketClientProtocol): await ws.ensure_open() except websockets.exceptions.ConnectionClosed: # ws got closed so let's just do a regular IDENTIFY connect. - log.info('RESUME failed (the websocket decided to close) for Shard ID %s. Retrying.', shard_id) + log.warning('RESUME failed (the websocket decided to close) for Shard ID %s. Retrying.', shard_id) return await cls.from_client(client, shard_id=shard_id) else: return ws @@ -373,7 +373,7 @@ class DiscordWebSocket(websockets.client.WebSocketClientProtocol): # "reconnect" can only be handled by the Client # so we terminate our connection and raise an # internal exception signalling to reconnect. - log.info('Received RECONNECT opcode.') + log.debug('Received RECONNECT opcode.') await self.close() raise ResumeWebSocket(self.shard_id) diff --git a/discord/state.py b/discord/state.py index fcfed7d9..046b548d 100644 --- a/discord/state.py +++ b/discord/state.py @@ -314,7 +314,9 @@ class ConnectionState: try: await utils.sane_wait_for(chunks, timeout=len(chunks) * 30.0) except asyncio.TimeoutError: - log.info('Somehow timed out waiting for chunks.') + log.warning('Somehow timed out waiting for chunks.') + else: + log.info('Finished requesting guild member chunks for %d guilds.', len(guilds)) async def query_members(self, guild, query, limit, cache): guild_id = guild.id @@ -339,7 +341,7 @@ class ConnectionState: return members except asyncio.TimeoutError: - log.info('Timed out waiting for chunks with query %r and limit %d for guild_id %d', query, limit, guild_id) + log.warning('Timed out waiting for chunks with query %r and limit %d for guild_id %d', query, limit, guild_id) raise async def _delay_ready(self): @@ -884,7 +886,7 @@ class ConnectionState: guild_id = int(data['guild_id']) guild = self._get_guild(guild_id) members = [Member(guild=guild, data=member, state=self) for member in data.get('members', [])] - log.info('Processed a chunk for %s members in guild ID %s.', len(members), guild_id) + log.debug('Processed a chunk for %s members in guild ID %s.', len(members), guild_id) if self._cache_members: for member in members: existing = guild.get_member(member.id) @@ -1055,6 +1057,8 @@ class AutoShardedConnectionState(ConnectionState): await utils.sane_wait_for(chunks, timeout=len(chunks) * 30.0) except asyncio.TimeoutError: log.info('Somehow timed out waiting for chunks.') + else: + log.info('Finished requesting guild member chunks for %d guilds.', len(guilds)) async def _delay_ready(self): launch = self._ready_state.launch |