We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f1209dc commit 9fbbfb9Copy full SHA for 9fbbfb9
2 files changed
pyproject.toml
@@ -1,6 +1,6 @@
1
[project]
2
name = "deltadefi"
3
-version = "0.1.2"
+version = "0.1.3"
4
description = "Python SDK for DeltaDeFi protocol."
5
readme = "README.md"
6
requires-python = ">3.11,<4.0.0"
src/deltadefi/clients/websocket.py
@@ -187,10 +187,8 @@ async def _reconnect(self) -> None:
187
# In a more complex implementation, you'd want to handle multiple concurrent subscriptions
188
if self.subscriptions:
189
first_sub = next(iter(self.subscriptions.values()))
190
- if first_sub.get("type") == "trade":
191
- await self.connect(first_sub["endpoint"])
192
- else:
193
- await self.connect()
+ # Always use the stored endpoint for reconnection
+ await self.connect(first_sub["endpoint"])
194
else:
195
await self.connect()
196
0 commit comments