X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=planetstack%2Fhpc_observer%2Fsteps%2Fsync_hpcservices.py;h=d8d7ba5e8c48479dc683c6fbea5770df31efc00a;hb=d54b2b24a873e684b415c0359591ae77f4946f0a;hp=a4c9e77a66d83b138f6fde28867f6cd40b7af3b7;hpb=27111c67910d9a5f9bb98ff0d0ac121a8476d6a6;p=plstackapi.git

diff --git a/planetstack/hpc_observer/steps/sync_hpcservices.py b/planetstack/hpc_observer/steps/sync_hpcservices.py
index a4c9e77..d8d7ba5 100644
--- a/planetstack/hpc_observer/steps/sync_hpcservices.py
+++ b/planetstack/hpc_observer/steps/sync_hpcservices.py
@@ -25,8 +25,12 @@ class SyncHpcService(SyncStep, HpcLibrary):
         SyncStep.__init__(self, **args)
         HpcLibrary.__init__(self)
 
-    def fetch_pending(self):
-        return HpcService.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
+    def fetch_pending(self, deleted):
+        # Looks like deletion is not supported for this object - Sapan
+        if (deleted):
+            return []
+        else:
+            return HpcService.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
 
     def sync_record(self, hpc_service):
         logger.info("sync'ing hpc_service %s" % str(hpc_service))