Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
Drapersniper committed Mar 18, 2022
1 parent 4cdcea7 commit 44b4ce8
Showing 1 changed file with 9 additions and 7 deletions.
16 changes: 9 additions & 7 deletions lavalink/node.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,12 @@
)
from .player_manager import PlayerManager
from .rest_api import Track
from .utils import task_callback_exception, task_callback_debug, task_callback_verbose, task_callback_trace
from .utils import (
task_callback_exception,
task_callback_debug,
task_callback_verbose,
task_callback_trace,
)
from .errors import AbortingNodeConnection, NodeNotReady, NodeNotFound

__all__ = [
Expand Down Expand Up @@ -370,9 +375,7 @@ async def listener(self):
self.reconnect_task = self.loop.create_task(
self._reconnect(self._is_shutdown)
)
self.reconnect_task.add_done_callback(
task_callback_debug
)
self.reconnect_task.add_done_callback(task_callback_debug)
return
else:
ws_ll_log.info("[NODE] | Listener closing: %s", msg.extra)
Expand Down Expand Up @@ -409,9 +412,8 @@ async def listener(self):
self.reconnect_task.cancel()
self.update_state(NodeState.RECONNECTING)
self.reconnect_task = self.loop.create_task(self._reconnect(self._is_shutdown))
self.reconnect_task.add_done_callback(
task_callback_debug
)
self.reconnect_task.add_done_callback(task_callback_debug)

async def _handle_op(self, op: LavalinkIncomingOp, data):
if op == LavalinkIncomingOp.EVENT:
try:
Expand Down

0 comments on commit 44b4ce8

Please sign in to comment.