From c9b6820ae44ee7ef8039936eb1bf9fec8b1b4694 Mon Sep 17 00:00:00 2001 From: Sapan Bhatia Date: Wed, 23 Jul 2014 09:34:02 -0400 Subject: [PATCH] User deleter, refactored --- planetstack/openstack_observer/steps/sync_users.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/planetstack/openstack_observer/steps/sync_users.py b/planetstack/openstack_observer/steps/sync_users.py index 9d88918..2852b73 100644 --- a/planetstack/openstack_observer/steps/sync_users.py +++ b/planetstack/openstack_observer/steps/sync_users.py @@ -11,11 +11,13 @@ class SyncUsers(OpenStackSyncStep): provides=[User] requested_interval=0 - def fetch_pending(self): - return User.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None)) - def sync_record(self, user): for user_deployment in UserDeployments.objects.filter(user=user): # bump the 'updated' field so user account are updated across # deployments. user_deployment.save() + + def delete_record(self, user): + user_deployment_deleter = UserDeploymentDeleter() + for user_deployment in UserDeployments.objects.filter(user=user): + user_deployment_deleter(user_deployment.id) -- 2.43.0