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
10 from observer.ansible import *
12 logger = Logger(level=logging.INFO)
14 class SyncControllerImages(OpenStackSyncStep):
15 provides=[ControllerImages]
18 def fetch_pending(self, deleted):
22 # now we return all images that need to be enacted
23 return ControllerImages.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
25 def sync_record(self, controller_image):
26 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,
32 'ansible_tag': '%s@%s'%(controller_image.image.name,controller_image.controller.name), # name of ansible playbook
35 res = run_template('sync_controller_images.yaml', image_fields, path='controller_images')
38 raise Exception('Could not sync image %s'%controller_image.image.name)
40 image_id = res[0]['id']
41 controller_image.glance_image_id = image_id
42 controller_image.save()