planetstack/ec2_observer/steps/sync_users.py

   1 import os
   2 import base64
   3 import hashlib
   4 from django.db.models import F, Q
   5 from planetstack.config import Config
   6 from observer.openstacksyncstep import OpenStackSyncStep
   7 from core.models.user import User, UserDeployments
   8
   9 class SyncUsers(OpenStackSyncStep):
  10     provides=[User]
  11     requested_interval=0
  12
  13     def fetch_pending(self):
  14         return User.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
  15
  16     def sync_record(self, user):
  17         for user_deployment in UserDeployments.objects.filter(user=user):
  18             # bump the 'updated' field so user account are updated across
  19             # deployments.
  20             user_deployment.save()