commit f6bb2cf526f75f3a9220e3e53f89e30b83ca99a3
author Jeremy Mowery <jermowery@email.arizona.edu> Tue Nov 17 19:43:45 2015 -0700
committer Jeremy Mowery <jermowery@email.arizona.edu> Tue Nov 17 19:43:45 2015 -0700
tree 5d4a2386ff5a386f187fdb8fbcafac14c1b2086d
parent c68e6b20aabe33b66e2e3650a81bf52e4ae993a8

Fixing HelloWorldService?

xos/observers/helloworldservice/steps/sync_helloworldtenant.py

diff --git a/xos/observers/helloworldservice/steps/sync_helloworldtenant.py b/xos/observers/helloworldservice/steps/sync_helloworldtenant.py
index 5110afb..6e40f28 100644
--- a/xos/observers/helloworldservice/steps/sync_helloworldtenant.py
+++ b/xos/observers/helloworldservice/steps/sync_helloworldtenant.py
@@ -4,13 +4,13 @@
 from helloworldservice.models import HelloWorldService, HelloWorldTenant
 from observers.base.SyncInstanceUsingAnsible import SyncInstanceUsingAnsible
 
-parentdir = os.path.join(os.path.dirname(__file__),"..")
-sys.path.insert(0,parentdir)
+parentdir = os.path.join(os.path.dirname(__file__), "..")
+sys.path.insert(0, parentdir)
 
 class SyncHelloWorldServiceTenant(SyncInstanceUsingAnsible):
-    provides=[HelloWorldTenant]
-    observes=HelloWorldTenant
-    requested_interval= 0
+    provides = [HelloWorldTenant]
+    observes = HelloWorldTenant
+    requested_interval = 0
     template_name = "sync_helloworldtenant.yaml"
     service_key_name = "/opt/xos/observers/helloworldservice/helloworldservice_private_key"
 
@@ -19,17 +19,17 @@
 
     def fetch_pending(self, deleted):
         if (not deleted):
-            objs = HelloWorldTenant.get_tenant_objects().filter(
-                    Q(enacted__lt=F('updated')) | Q(enacted=None),
-                    Q(lazy_blocked=False))
+            objs = HelloWorldTenant.get_tenant_objects().filter(Q(enacted__lt=F('updated')) | Q(enacted=None),Q(lazy_blocked=False))
         else:
             objs = HelloWorldTenant.get_deleted_tenant_objects()
 
         return objs
 
     def get_extra_attributes(self, o):
-    	self.get_instance(o)
     	return {"display_message": o.display_message}
 
+    def run_playbook(self, o, fields):
+        super(SyncHelloWorldServiceTenant, self).run_playbook(o, fields)
+
     def delete_record(self, m):
         pass