diff --git a/fedn/fedn/network/combiner/roundhandler.py b/fedn/fedn/network/combiner/roundhandler.py index 3956858e0..8d87b2b69 100644 --- 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 index 255e77b2e..fa211f2ae 100644 --- 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 index cc5416fde..027584444 100644 --- 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: