diff --git a/logs_parser.py b/logs_parser.py
index 49250c3..5185497 100644
--- a/logs_parser.py
+++ b/logs_parser.py
@@ -44,9 +44,12 @@ def parse_logs(timeout):
                         unsuccessful_attempts += 1
                         retry_info = data["message"].split("Retry ")[1].strip("()")
                         current_retry, max_retry = map(int, retry_info.split("/"))
-                        #if current_retry == max_retry:
-                        #    print(f"Max Retry Reached: {data}", flush=True)
-                        #    return False, "Max Retry Reached"
+                        if current_retry == max_retry:
+                            print(f"Max Retry Reached: {data}", flush=True)
+                            return False, "Max Retry Reached"
+                    elif data.get("message") == "Error getting latest open worker nonce on topic":
+                        print(f"Error: {data}", flush=True)
+                        return False, "Error getting latest open worker nonce on topic"
         except Exception as e:
             print(f"Exception occurred: {e}", flush=True)