SEBA-450 Update Att-Workflow-Driver to use synchronizer library
Change-Id: I86740c694950e86f2d7afea6221d33e2aad8aeef
diff --git a/xos/synchronizer/model_policies/model_policy_att_workflow_driver_whitelistentry.py b/xos/synchronizer/model_policies/model_policy_att_workflow_driver_whitelistentry.py
index 51f2ba4..f063cc4 100644
--- a/xos/synchronizer/model_policies/model_policy_att_workflow_driver_whitelistentry.py
+++ b/xos/synchronizer/model_policies/model_policy_att_workflow_driver_whitelistentry.py
@@ -14,8 +14,7 @@
# limitations under the License.
-from synchronizers.new_base.modelaccessor import AttWorkflowDriverServiceInstance, AttWorkflowDriverWhiteListEntry, model_accessor
-from synchronizers.new_base.policy import Policy
+from xossynchronizer.model_policies.policy import Policy
import os
import sys
@@ -31,7 +30,7 @@
self.handle_update(whitelist)
def validate_onu_state(self, si):
- [valid, message] = AttHelpers.validate_onu(self.logger, si)
+ [valid, message] = AttHelpers.validate_onu(self.model_accessor, self.logger, si)
si.status_message = message
if valid:
si.onu_state = "ENABLED"
@@ -46,7 +45,7 @@
def handle_update(self, whitelist):
self.logger.debug("MODEL_POLICY: handle_update for AttWorkflowDriverWhiteListEntry", whitelist=whitelist)
- sis = AttWorkflowDriverServiceInstance.objects.all()
+ sis = self.model_accessor.AttWorkflowDriverServiceInstance.objects.all()
for si in sis:
@@ -66,7 +65,7 @@
assert(whitelist.owner)
- sis = AttWorkflowDriverServiceInstance.objects.all()
+ sis = self.model_accessor.AttWorkflowDriverServiceInstance.objects.all()
sis = [si for si in sis if si.serial_number.lower() == whitelist.serial_number.lower()]
for si in sis: