X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=planetstack%2Fhpc_observer%2Fsteps%2Fsync_originserver.py;fp=planetstack%2Fhpc_observer%2Fsteps%2Fsync_originserver.py;h=4f0ba4ce915728f54c4d1304ed830b4380e1dd6d;hb=6904f802c2f5b8692ea21dfe07b737c5f5882d1f;hp=e57c282247dcced4c74c7922a621546ee47a8859;hpb=d54b2b24a873e684b415c0359591ae77f4946f0a;p=plstackapi.git

diff --git a/planetstack/hpc_observer/steps/sync_originserver.py b/planetstack/hpc_observer/steps/sync_originserver.py
index e57c282..4f0ba4c 100644
--- a/planetstack/hpc_observer/steps/sync_originserver.py
+++ b/planetstack/hpc_observer/steps/sync_originserver.py
@@ -24,9 +24,6 @@ class SyncOriginServer(SyncStep, HpcLibrary):
         SyncStep.__init__(self, **args)
         HpcLibrary.__init__(self)
 
-    def fetch_pending(self):
-        return OriginServer.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
-
     def sync_record(self, ors):
         logger.info("sync'ing origin server %s" % str(ors))
 
@@ -56,3 +53,6 @@ class SyncOriginServer(SyncStep, HpcLibrary):
         self.client.cob.UpdateContent(ors.origin_server_id, {"url": url})
 
         ors.save()
+
+    def delete(self, m):
+        self.client.onev.Delete("OriginServer", m.origin_server_id)