From 4bb6b6ae994dbb0f60dd265bab74c8be08becea7 Mon Sep 17 00:00:00 2001
From: Anton <43762166+smypmsa@users.noreply.github.com>
Date: Sun, 15 Jun 2025 20:48:32 +0200
Subject: [PATCH] Update src/monitoring/pumpportal_listener.py

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
---
 src/monitoring/pumpportal_listener.py | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/monitoring/pumpportal_listener.py b/src/monitoring/pumpportal_listener.py
index a9899ec..afd6f6b 100644
--- a/src/monitoring/pumpportal_listener.py
+++ b/src/monitoring/pumpportal_listener.py
@@ -83,13 +83,17 @@ class PumpPortalListener(BaseTokenListener):
 
                     except websockets.exceptions.ConnectionClosed:
                         logger.warning("PumpPortal WebSocket connection closed. Reconnecting...")
+                    finally:
                         ping_task.cancel()
+                        try:
+                            await ping_task
+                        except asyncio.CancelledError:
+                            pass
 
-            except Exception as e:
-                logger.error(f"PumpPortal WebSocket connection error: {e}")
+            except Exception:
+                logger.exception("PumpPortal WebSocket connection error")
                 logger.info("Reconnecting in 5 seconds...")
                 await asyncio.sleep(5)
-
     async def _subscribe_to_new_tokens(self, websocket) -> None:
         """Subscribe to new token events from PumpPortal.