Update after review

scaleoutsystems · Jan 30, 2024 · 28ab8ba · 28ab8ba
1 parent 9e83599
commit 28ab8ba
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/fedn/fedn/network/combiner/roundhandler.py b/fedn/fedn/network/combiner/roundhandler.py
@@ -54,7 +54,7 @@ def push_round_config(self, round_config):
             round_config['_job_id'] = str(uuid.uuid4())
             self.round_configs.put(round_config)
         except Exception:
-            logger.warning("Failed to push round config.")
+            logger.error("Failed to push round config.")
             raise
         return round_config['_job_id']
 
@@ -217,11 +217,11 @@ def stage_model(self, model_id, timeout_retry=3, retry=2):
                 if model:
                     break
             except Exception:
-                logger.info("Could not fetch model from storage backend, retrying.")
+                logger.warning("Could not fetch model from storage backend, retrying.")
                 time.sleep(timeout_retry)
                 tries += 1
                 if tries > retry:
-                    logger.info("Failed to stage model {} from storage backend!".format(model_id))
+                    logger.error("Failed to stage model {} from storage backend!".format(model_id))
                     raise
 
         self.modelservice.set_model(model, model_id)

diff --git a/fedn/fedn/network/controller/control.py b/fedn/fedn/network/controller/control.py
@@ -95,7 +95,7 @@ def session(self, config):
             return
 
         if not self.statestore.get_latest_model():
-            logger.info("No model in model chain, please provide a seed model!")
+            logger.warning("No model in model chain, please provide a seed model!")
             return
 
         self._state = ReducerState.instructing
@@ -336,7 +336,7 @@ def infer_instruct(self, config):
 
         # Check for a model chain
         if not self.statestore.latest_model():
-            logger.info("No model in model chain, please seed the alliance!")
+            logger.warning("No model in model chain, please set seed model.")
 
         # Set reducer in monitoring state
         self.__state = ReducerState.monitoring
@@ -361,7 +361,7 @@ def inference_round(self, config):
 
         # Check for at least one combiner in statestore
         if len(self.network.get_combiners()) < 1:
-            logger.warning("REDUCER: No combiners connected!")
+            logger.warning("No combiners connected!")
             return round_data
 
         # Setup combiner configuration

diff --git a/fedn/fedn/network/controller/controlbase.py b/fedn/fedn/network/controller/controlbase.py
@@ -51,7 +51,7 @@ def __init__(self, statestore):
                 if storage_config:
                     not_ready = False
                 else:
-                    logger.info("Storage backend not configured, waiting...")
+                    logger.warning("Storage backend not configured, waiting...")
                     sleep(5)
                     tries += 1
                     if tries > MAX_TRIES_BACKEND: