mirror of
https://github.com/aljazceru/python-teos.git
synced 2025-12-18 06:34:19 +01:00
Fixes prefix encoding
This commit is contained in:
@@ -20,7 +20,7 @@ class DBManager:
|
|||||||
def load_appointments_db(self, prefix):
|
def load_appointments_db(self, prefix):
|
||||||
data = {}
|
data = {}
|
||||||
|
|
||||||
for k, v in self.db.iterator(prefix=prefix):
|
for k, v in self.db.iterator(prefix=prefix.encode('utf-8')):
|
||||||
# Get uuid and appointment_data from the db
|
# Get uuid and appointment_data from the db
|
||||||
uuid = k[1:].decode('utf-8')
|
uuid = k[1:].decode('utf-8')
|
||||||
data[uuid] = json.loads(v)
|
data[uuid] = json.loads(v)
|
||||||
|
|||||||
@@ -122,7 +122,7 @@ class Responder:
|
|||||||
txs_to_rebroadcast = self.get_txs_to_rebroadcast(txs)
|
txs_to_rebroadcast = self.get_txs_to_rebroadcast(txs)
|
||||||
completed_jobs = self.get_completed_jobs(height)
|
completed_jobs = self.get_completed_jobs(height)
|
||||||
|
|
||||||
Cleaner.delete_completed_jobs(self.jobs, self.tx_job_map, completed_jobs, height)
|
Cleaner.delete_completed_jobs(self.jobs, self.tx_job_map, completed_jobs, height, self.db_manager)
|
||||||
self.rebroadcast(txs_to_rebroadcast)
|
self.rebroadcast(txs_to_rebroadcast)
|
||||||
|
|
||||||
# NOTCOVERED
|
# NOTCOVERED
|
||||||
|
|||||||
Reference in New Issue
Block a user