- sender_name = sender.__name__
- policy_name = 'model_policy_%s'%sender_name
- if (not kwargs['update_fields']):
- noargs = True
- deleted = False
- else:
- noargs = False
- deleted = True
+def run_policy():
+ from core.models import Slice,Controller,Network,User,SlicePrivilege,Site,SitePrivilege,Image,ControllerSlice
+ while (True):
+ start = time.time()
+ models = [Slice, Controller, Network, User, SlicePrivilege, Site, SitePrivilege, Image, ControllerSlice]
+ objects = []
+
+ for m in models:
+ res = m.objects.filter(Q(policed__lt=F('updated')) | Q(policed=None))
+ objects.extend(res)