Merge pull request #326 from ahtohio/do-not-sleep-after-watch

#minor Remove unnecessary sleep before each watch cycle
kiwigrid · Feb 28, 2024 · ac2354a · ac2354a
2 parents 34e16c9 + ed1518d
commit ac2354a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/resources.py b/src/resources.py
@@ -365,8 +365,6 @@ def _watch_resource_iterator(label, label_value, target_folder, request_url, req
 def _watch_resource_loop(mode, *args):
     while True:
         try:
-            # Always wait to slow down the loop in case of exceptions
-            sleep(int(os.getenv("ERROR_THROTTLE_SLEEP", 5)))
             if mode == "SLEEP":
                 list_resources(*args)
                 sleep(int(os.getenv("SLEEP_TIME", 60)))
@@ -379,11 +377,14 @@ def _watch_resource_loop(mode, *args):
                 raise
         except ProtocolError as e:
             logger.error(f"ProtocolError when calling kubernetes: {e}\n")
+            sleep(int(os.getenv("ERROR_THROTTLE_SLEEP", 5)))
         except MaxRetryError as e:
             logger.error(f"MaxRetryError when calling kubernetes: {e}\n")
+            sleep(int(os.getenv("ERROR_THROTTLE_SLEEP", 5)))
         except Exception as e:
             logger.error(f"Received unknown exception: {e}\n")
             traceback.print_exc()
+            sleep(int(os.getenv("ERROR_THROTTLE_SLEEP", 5)))
 
 
 def watch_for_changes(mode, label, label_value, target_folder, request_url, request_method, request_payload,