From cd9f90f0429dcb235c491c34a86efd90274ddecb Mon Sep 17 00:00:00 2001
From: David Trattnig <david.trattnig@o94.at>
Date: Thu, 21 Nov 2019 14:07:24 +0100
Subject: [PATCH] Cleanup and fixes.
---
modules/communication/redis/adapter.py | 3 +--
modules/scheduling/scheduler.py | 4 ++--
2 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/modules/communication/redis/adapter.py b/modules/communication/redis/adapter.py
index 5406ae1d..ad97f8d8 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 8f741fcf..e7828f84 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)
--
GitLab