From 44b4ce84274c392a6c39c11fbd247d9ef473c36c Mon Sep 17 00:00:00 2001 From: Draper <27962761+Drapersniper@users.noreply.github.com> Date: Fri, 18 Mar 2022 16:32:46 +0000 Subject: [PATCH] formatting --- lavalink/node.py | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/lavalink/node.py b/lavalink/node.py index 9a66a0ab..4112aa9b 100644 --- a/lavalink/node.py +++ b/lavalink/node.py @@ -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__ = [ @@ -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) @@ -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: