3 from collections import defaultdict
4 from django.db.models import F, Q
5 from planetstack.config import Config
6 from observer.openstacksyncstep import OpenStackSyncStep
7 from core.models import Controller
8 from core.models import Image, ControllerImages
9 from util.logger import Logger, logging
11 logger = Logger(level=logging.INFO)
13 class SyncControllerImages(OpenStackSyncStep):
14 provides=[ControllerImages]
17 def fetch_pending(self, deleted):
21 # now we return all images that need to be enacted
22 return ControllerImages.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
24 def sync_record(self, controller_image):
25 logger.info("Working on image %s on controller %s" % (controller_image.image.name, controller_image.controller))
27 image_fields = {'endpoint':controller_image.controller.auth_url,
28 'admin_user':controller_image.controller.admin_user,
29 'admin_password':controller_image.controller.admin_password,
30 'name':controller_image.image.name,
31 'filepath':controller_image.image.path
34 res = run_template('sync_controller_images.yaml', image_fields)
37 raise Exception('Could not sync image %s'%controller_image.image.name)
39 image_id = res[0]['id']
40 controller_image.glance_image_id = image_id
41 controller_image.save()