diff --git a/pisa/db_manager.py b/pisa/db_manager.py index 61be27c..339140d 100644 --- a/pisa/db_manager.py +++ b/pisa/db_manager.py @@ -20,7 +20,7 @@ class DBManager: def load_appointments_db(self, prefix): 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 uuid = k[1:].decode('utf-8') data[uuid] = json.loads(v) diff --git a/pisa/responder.py b/pisa/responder.py index d843295..a9aa0c3 100644 --- a/pisa/responder.py +++ b/pisa/responder.py @@ -122,7 +122,7 @@ class Responder: txs_to_rebroadcast = self.get_txs_to_rebroadcast(txs) 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) # NOTCOVERED