diff --git a/watcher/decision_engine/strategy/strategies/basic_consolidation.py b/watcher/decision_engine/strategy/strategies/basic_consolidation.py
index d4929774b..9280bfd9b 100644
--- a/watcher/decision_engine/strategy/strategies/basic_consolidation.py
+++ b/watcher/decision_engine/strategy/strategies/basic_consolidation.py
@@ -308,7 +308,7 @@ class BasicConsolidation(base.ServerConsolidationBaseStrategy):
                 "for %(metric_name)s", dict(
                     resource_id=resource_id,
                     metric_name=self.METRIC_NAMES[
-                        self.config.datasource]['host_cpu_usage']))
+                        self.datasource_backend.NAME]['host_cpu_usage']))
             host_avg_cpu_util = 100
 
         total_cores_used = node.vcpus * (host_avg_cpu_util / 100.0)
@@ -328,7 +328,7 @@ class BasicConsolidation(base.ServerConsolidationBaseStrategy):
                 "for %(metric_name)s", dict(
                     resource_id=instance.uuid,
                     metric_name=self.METRIC_NAMES[
-                        self.config.datasource]['instance_cpu_usage']))
+                        self.datasource_backend.NAME]['instance_cpu_usage']))
             instance_cpu_utilization = 100
 
         total_cores_used = instance.vcpus * (instance_cpu_utilization / 100.0)
diff --git a/watcher/decision_engine/strategy/strategies/workload_balance.py b/watcher/decision_engine/strategy/strategies/workload_balance.py
index 1021948d1..b24590a5b 100644
--- a/watcher/decision_engine/strategy/strategies/workload_balance.py
+++ b/watcher/decision_engine/strategy/strategies/workload_balance.py
@@ -273,7 +273,7 @@ class WorkloadBalance(base.WorkloadStabilizationBaseStrategy):
                 except Exception as exc:
                     LOG.exception(exc)
                     LOG.error("Can not get %s from %s", self._meter,
-                              self.config.datasource)
+                              self.datasource_backend.NAME)
                     continue
                 if util is None:
                     LOG.debug("Instance (%s): %s is None",