From ba8e1b0eee401c7446c0bc40c256f87972f17e14 Mon Sep 17 00:00:00 2001 From: Sapan Bhatia Date: Wed, 23 Jul 2014 09:33:44 -0400 Subject: [PATCH 1/1] Slice deleter, refactored --- planetstack/openstack_observer/steps/sync_slices.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/planetstack/openstack_observer/steps/sync_slices.py b/planetstack/openstack_observer/steps/sync_slices.py index 6cf0772..c0b8abe 100644 --- a/planetstack/openstack_observer/steps/sync_slices.py +++ b/planetstack/openstack_observer/steps/sync_slices.py @@ -13,11 +13,17 @@ class SyncSlices(OpenStackSyncStep): provides=[Slice] requested_interval=0 - def fetch_pending(self): - return Slice.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None)) - def sync_record(self, slice): for slice_deployment in SliceDeployments.objects.filter(slice=slice): # bump the 'updated' timestamp and trigger observer to update # slice across all deployments slice_deployment.save() + + def delete_record(self, slice): + slice_deployment_deleter = SliceDeploymentDeleter() + for slice_deployment in SliceDeployments.objects.filter(slice=slice): + try: + slice_deployment_deleter(slice_deployment.id) + except Exception,e: + logger.log_exc("Failed to delete slice_deployment %s" % slice_deployment) + raise e -- 2.43.0