commit 1879ce770d403916f3b7cc4459f641193b459eeb
author Matteo Scandolo <matteo.scandolo@gmail.com> Tue May 30 15:45:26 2017 -0700
committer Matteo Scandolo <matteo.scandolo@gmail.com> Tue Jun 06 16:12:37 2017 -0700
tree b82a34a80544e14a92d72d1344b4b2225d15d4fb
parent 6a8df7e2ef24bf32b7b5a1e50c29bb6359c4fd27

[CORD-1360] Using new Config in synchronizers

Change-Id: Iaa7c3394971286f4823a906fc184b0b83ad7ebbd

xos/synchronizers/new_base/backend.py

diff --git a/xos/synchronizers/new_base/backend.py b/xos/synchronizers/new_base/backend.py
index eccd570..1ef2ec6 100644
--- a/xos/synchronizers/new_base/backend.py
+++ b/xos/synchronizers/new_base/backend.py
@@ -9,9 +9,9 @@
 from synchronizers.new_base.model_policy_loop import XOSPolicyEngine
 from synchronizers.new_base.modelaccessor import *
 from xos.logger import Logger, logging
-from xos.config import Config
+from xosconfig import Config
 
-watchers_enabled = getattr(Config(), "observer_enable_watchers", None)
+watchers_enabled = Config.get("enable_watchers")
 
 if (watchers_enabled):
     from synchronizers.new_base.watchers import XOSWatcher
@@ -56,7 +56,7 @@
 
         model_accessor.update_diag(sync_start=time.time(), backend_status="0 - Synchronizer Start")
 
-        steps_dir = Config().observer_steps_dir
+        steps_dir = Config.get("steps_dir")
         if steps_dir:
             sync_steps = self.load_sync_step_modules(steps_dir)
             if sync_steps:
@@ -74,7 +74,7 @@
             logger.info("Skipping observer and watcher threads due to no steps dir.")
 
         # start model policies thread
-        policies_dir = getattr(Config(), "observer_model_policies_dir", None)
+        policies_dir = Config.get("model_policies_dir")
         if policies_dir:
             policy_engine = XOSPolicyEngine(policies_dir=policies_dir)
             model_policy_thread = threading.Thread(target=policy_engine.run, name="policy_engine")