3 from django.db.models import F, Q
4 from planetstack.config import Config
5 from observer.openstacksyncstep import OpenStackSyncStep
6 from core.models.site import Site
8 class SyncSites(OpenStackSyncStep):
12 def fetch_pending(self):
13 return Site.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
15 def sync_record(self, site):
17 if not site.tenant_id:
18 tenant = self.driver.create_tenant(tenant_name=site.login_base,
19 description=site.name,
21 site.tenant_id = tenant.id
23 # XXX - What's caller?
24 # self.driver.add_user_role(self.caller.kuser_id, tenant.id, 'admin')
27 if site.id and site.tenant_id:
28 self.driver.update_tenant(site.tenant_id,
29 description=site.name,