diff --git a/watcher/decision_engine/strategy/strategies/basic_consolidation.py b/watcher/decision_engine/strategy/strategies/basic_consolidation.py index 890fb8b36..d4a06fa17 100644 --- a/watcher/decision_engine/strategy/strategies/basic_consolidation.py +++ b/watcher/decision_engine/strategy/strategies/basic_consolidation.py @@ -479,3 +479,4 @@ class BasicConsolidation(base.ServerConsolidationBaseStrategy): released_compute_nodes_count=self.number_of_released_nodes, instance_migrations_count=self.number_of_migrations, ) + LOG.debug(self.compute_model.to_string()) diff --git a/watcher/decision_engine/strategy/strategies/outlet_temp_control.py b/watcher/decision_engine/strategy/strategies/outlet_temp_control.py index cfa39ddf4..5af3627ea 100644 --- a/watcher/decision_engine/strategy/strategies/outlet_temp_control.py +++ b/watcher/decision_engine/strategy/strategies/outlet_temp_control.py @@ -230,6 +230,8 @@ class OutletTempControl(base.ThermalOptimizationBaseStrategy): if not self.compute_model: raise wexc.ClusterStateNotDefined() + LOG.debug(self.compute_model.to_string()) + def do_execute(self): # the migration plan will be triggered when the outlet temperature # reaches threshold @@ -284,3 +286,5 @@ class OutletTempControl(base.ThermalOptimizationBaseStrategy): def post_execute(self): self.solution.model = self.compute_model # TODO(v-francoise): Add the indicators to the solution + + LOG.debug(self.compute_model.to_string()) diff --git a/watcher/decision_engine/strategy/strategies/uniform_airflow.py b/watcher/decision_engine/strategy/strategies/uniform_airflow.py index 3b42ac8e3..c1aacebbb 100644 --- a/watcher/decision_engine/strategy/strategies/uniform_airflow.py +++ b/watcher/decision_engine/strategy/strategies/uniform_airflow.py @@ -293,6 +293,8 @@ class UniformAirflow(base.BaseStrategy): if not self.compute_model: raise wexc.ClusterStateNotDefined() + LOG.debug(self.compute_model.to_string()) + def do_execute(self): self.threshold_airflow = self.input_parameters.threshold_airflow self.threshold_inlet_t = self.input_parameters.threshold_inlet_t @@ -345,3 +347,5 @@ class UniformAirflow(base.BaseStrategy): def post_execute(self): self.solution.model = self.compute_model # TODO(v-francoise): Add the indicators to the solution + + LOG.debug(self.compute_model.to_string()) diff --git a/watcher/decision_engine/strategy/strategies/vm_workload_consolidation.py b/watcher/decision_engine/strategy/strategies/vm_workload_consolidation.py index 344c10f30..ca3bac519 100644 --- a/watcher/decision_engine/strategy/strategies/vm_workload_consolidation.py +++ b/watcher/decision_engine/strategy/strategies/vm_workload_consolidation.py @@ -498,6 +498,8 @@ class VMWorkloadConsolidation(base.ServerConsolidationBaseStrategy): if not self.compute_model: raise exception.ClusterStateNotDefined() + LOG.debug(self.compute_model.to_string()) + def do_execute(self): """Execute strategy. @@ -548,3 +550,5 @@ class VMWorkloadConsolidation(base.ServerConsolidationBaseStrategy): released_compute_nodes_count=self.number_of_migrations, instance_migrations_count=self.number_of_released_nodes, ) + + LOG.debug(self.compute_model.to_string()) diff --git a/watcher/decision_engine/strategy/strategies/workload_balance.py b/watcher/decision_engine/strategy/strategies/workload_balance.py index 8d2c5ce70..5dba465b9 100644 --- a/watcher/decision_engine/strategy/strategies/workload_balance.py +++ b/watcher/decision_engine/strategy/strategies/workload_balance.py @@ -283,6 +283,8 @@ class WorkloadBalance(base.WorkloadStabilizationBaseStrategy): if not self.compute_model: raise wexc.ClusterStateNotDefined() + LOG.debug(self.compute_model.to_string()) + def do_execute(self): """Strategy execution phase @@ -344,3 +346,5 @@ class WorkloadBalance(base.WorkloadStabilizationBaseStrategy): This can be used to compute the global efficacy """ self.solution.model = self.compute_model + + LOG.debug(self.compute_model.to_string()) diff --git a/watcher/decision_engine/strategy/strategies/workload_stabilization.py b/watcher/decision_engine/strategy/strategies/workload_stabilization.py index 4baa8f63f..0d40cafc8 100644 --- a/watcher/decision_engine/strategy/strategies/workload_stabilization.py +++ b/watcher/decision_engine/strategy/strategies/workload_stabilization.py @@ -363,7 +363,7 @@ class WorkloadStabilization(base.WorkloadStabilizationBaseStrategy): def create_migration_instance(self, mig_instance, mig_source_node, mig_destination_node): - """Create migration VM """ + """Create migration VM""" if self.compute_model.migrate_instance( mig_instance, mig_source_node, mig_destination_node): self.add_migration(mig_instance.uuid, 'live', @@ -437,3 +437,5 @@ class WorkloadStabilization(base.WorkloadStabilizationBaseStrategy): This can be used to compute the global efficacy """ self.fill_solution() + + LOG.debug(self.compute_model.to_string())