From 4d6842f94266d8fde691949bced263676b75be7b Mon Sep 17 00:00:00 2001
From: "Joshua M. Boniface" <joshua@boniface.me>
Date: Mon, 19 Jul 2021 13:09:36 -0400
Subject: [PATCH] Don't bail out if write fails, keep retrying

---
 daemon-common/log.py | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/daemon-common/log.py b/daemon-common/log.py
index 37e79fc2..9f513cb6 100644
--- a/daemon-common/log.py
+++ b/daemon-common/log.py
@@ -227,8 +227,15 @@ class ZookeeperLogger(Thread):
                 date = ''
             # Add the message to the deque
             logs.append(f'{date}{message}')
-            # Write the updated messages into Zookeeper
-            self.zkhandler.write([(('logs.messages', self.node), '\n'.join(logs))])
+
+            while True:
+                try:
+                    # Write the updated messages into Zookeeper
+                    self.zkhandler.write([(('logs.messages', self.node), '\n'.join(logs))])
+                    break
+                except Exception:
+                    sleep(0.1)
+                    continue
         return
 
     def stop(self):