diff --git a/modules/communication/redis/adapter.py b/modules/communication/redis/adapter.py index 5406ae1dda4ddbff7474c67d68cda59bb862d26a..ad97f8d8f47b1ed59a348308e51467cad4d990f9 100644 --- a/modules/communication/redis/adapter.py +++ b/modules/communication/redis/adapter.py @@ -224,9 +224,8 @@ class ServerRedisAdapter(threading.Thread, RedisMessenger): if self.shutdown_event.is_set(): return self.shutdown_event.set() - result = 'failed' try: - result = self.socket.unbind("tcp://"+self.ip+":"+self.port) + self.socket.unbind("tcp://"+self.ip+":"+self.port) except: pass diff --git a/modules/scheduling/scheduler.py b/modules/scheduling/scheduler.py index 8f741fcf892de311f663ad62e5113f1e11a5f86a..e7828f84b2f1581aceb0679fe6437e74e663bc57 100644 --- a/modules/scheduling/scheduler.py +++ b/modules/scheduling/scheduler.py @@ -130,7 +130,7 @@ class AuraScheduler(ExceptionLogger, threading.Thread): def run(self): """ - Called when thread is started via `start()`. It calls `self.fetch_new_program()` + Called when thread is started via `start()`. It calls `self.fetch_new_programme()` periodically depending on the `fetching_frequency` define engine configuration. """ while not self.exit_event.is_set(): @@ -202,7 +202,7 @@ class AuraScheduler(ExceptionLogger, threading.Thread): programme_as_string = "" if self.programme is None or len(self.programme) == 0: - self.fetch_new_program() + self.fetch_new_programme() try: programme_as_string = json.dumps([p._asdict() for p in self.programme], default=alchemyencoder)