need tests (#51)

Co-authored-by: Maxim Kolomeychenko <[email protected]>
Co-authored-by: Nikolai Petukhov <[email protected]>

agent/worker/task_app.py

@@ -721,6 +721,11 @@ def process_logs(self):
         def _process_line(log_line):
             # log_line = log_line.decode("utf-8")
             msg, res_log, lvl = self.parse_log_line(log_line)
+            if msg is None:
+                self.logger.warn(
+                    "Received empty (none) message in log line, will be handled automatically"
+                )
+                msg = "empty message"
             self._process_report(msg)
             output = self.call_event_function(res_log)
 

agent/worker/task_dockerized.py

@@ -347,6 +347,10 @@ def process_logs(self):
             self.logger.warn("No logs obtained from container.")  # check if bug occurred
 
     def _process_report(self, log_msg: str):
+        if log_msg is None:
+            self.logger.warn("Received empty (none) message in process task report")
+            return
+
         err_title, err_desc = None, None
         splits = log_msg.split(":")