hive-service: Fix

gbenson · Nov 27, 2024 · 51673aa · 51673aa
1 parent d0cb8fb
commit 51673aa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/libs/service/hive/service/service.py b/libs/service/hive/service/service.py
@@ -66,5 +66,5 @@ def publisher_connection(self, **kwargs) -> Connection:
         return self._connect(publisher_connection, kwargs)
 
     def _connect(self, connect, kwargs) -> Connection:
-        on_channel_open = kwargs.get("on_channel_open", self.on_channel_open)
+        on_channel_open = kwargs.pop("on_channel_open", self.on_channel_open)
         return connect(on_channel_open=on_channel_open, **kwargs)