Origin server deleter, refactored
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 @@
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 @@
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)