fix: priority fee sub blocks (#86)

.bumpversion.cfg

@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 0.7.14
+current_version = 0.7.15
 commit = True
 tag = True
 tag_name = {new_version}

CHANGELOG.md

@@ -48,4 +48,8 @@ Add default `Confirmed` commitment in `StandardTxSender`
 
 ## [0.7.14] - 2024-1-18
 
-Add `PriorityFeeSubscriber`
+Add `PriorityFeeSubscriber`
+
+## [0.7.15] - 2024-1-18
+
+Fix bug where `PriorityFeeSubscriber.subscribe()` blocks

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "driftpy"
-version = "0.7.14"
+version = "0.7.15"
 description = "A Python client for the Drift DEX"
 authors = ["x19 <https://twitter.com/[email protected]>", "bigz <https://twitter.com/bigz_pubkey>"]
 license = "MIT"

src/driftpy/__init__.py

@@ -1 +1 @@
-__version__ = "0.7.14"
+__version__ = "0.7.15"

src/driftpy/priority_fees/priority_fee_subscriber.py

@@ -2,7 +2,6 @@
 import jsonrpcclient
 
 from dataclasses import dataclass
-from typing import Optional
 
 from solana.rpc.async_api import AsyncClient
 from solders.pubkey import Pubkey
@@ -35,8 +34,11 @@ async def subscribe(self):
 
         self.subscribed = True
 
+        asyncio.create_task(self.poll())
+
+    async def poll(self):
         while self.subscribed:
-            await self.load()
+            asyncio.create_task(self.load())
             await asyncio.sleep(self.frequency_ms)
 
     async def load(self):
@@ -70,6 +72,8 @@ async def load(self):
         ) / len(desc_results)
         self.max_priority_fee = max(item["prioritizationFee"] for item in desc_results)
 
+        print("loaded")
+
     async def unsubscribe(self):
         if self.subscribed:
             self.subscribed = False