Skip to content

Commit

Permalink
#minor Remove unnecessary sleep after each watch cycle
Browse files Browse the repository at this point in the history
  • Loading branch information
Anton Chub committed Feb 13, 2024
1 parent 8214130 commit ed1518d
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)))
Expand All @@ -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,
Expand Down

0 comments on commit ed1518d

Please sign in to comment.