4 from django.db.models import F, Q
5 from planetstack.config import Config
6 from observer.syncstep import SyncStep
7 from core.models import Service
8 from hpc.models import HpcService
9 from requestrouter.models import RequestRouterService
10 from util.logger import Logger, logging
12 # hpclibrary will be in steps/..
13 parentdir = os.path.join(os.path.dirname(__file__),"..")
14 sys.path.insert(0,parentdir)
\r
16 from hpclib import HpcLibrary
18 logger = Logger(level=logging.INFO)
20 class SyncHpcService(SyncStep, HpcLibrary):
24 def __init__(self, **args):
25 SyncStep.__init__(self, **args)
26 HpcLibrary.__init__(self)
28 def fetch_pending(self, deleted):
29 # Looks like deletion is not supported for this object - Sapan
33 return HpcService.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
35 def sync_record(self, hpc_service):
36 logger.info("sync'ing hpc_service %s" % str(hpc_service))
37 self.write_slices_file(hpc_service, None)