CIRCL
/
AIL-framework
mirror of https://github.com/CIRCL/AIL-framework
2
1
Fork 0
Code Issues Releases Wiki Activity

chg: [modules] set log level to critcal on unexpected errors

pull/559/head
Terrtia 2021-04-02 16:41:11 +02:00
parent 77a708845c
commit dca806963c
No known key found for this signature in database
GPG Key ID: 1E1B1F50D84613D0
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bin/module/abstract_module.py
View File

@ -56,16 +56,16 @@ class AbstractModule(ABC):
""" """
Run Module endless process Run Module endless process
""" """
# Endless loop processing messages from the input queue # Endless loop processing messages from the input queue
while self.proceed: while self.proceed:
# Get one message (paste) from the QueueIn (copy of Redis_Global publish) # Get one message (paste) from the QueueIn (copy of Redis_Global publish)
message = self.process.get_from_set() message = self.process.get_from_set()
if message is None: if message is None:
self.computeNone() self.computeNone()
# Wait before next process # Wait before next process
self.redis_logger.debug('%s, waiting for new message, Idling %ds'%(self.module_name, self.pending_seconds)) self.redis_logger.debug(f"{self.module_name}, waiting for new message, Idling {self.pending_seconds}s")
time.sleep(self.pending_seconds) time.sleep(self.pending_seconds)
continue continue
@ -73,7 +73,7 @@ class AbstractModule(ABC):
# Module processing with the message from the queue # Module processing with the message from the queue
self.compute(message) self.compute(message)
except Exception as err: except Exception as err:
self.redis_logger.error("Error in module %s: %s"%(self.module_name, err)) self.redis_logger.critical(f"Error in module {self.module_name}: {err}")
def _module_name(self): def _module_name(self):