marcoduif/cdist
1
0
Fork 0
forked from ungleich-public/cdist
Code Issues Pull requests 1 Projects Releases Wiki Activity

begin use of cdist.core.Object.list_objects()

Browse source 
Signed-off-by: Nico Schottelius <nico@kr.ethz.ch>
This commit is contained in:
Nico Schottelius 2011-10-06 18:26:55 +02:00
parent bfba1938ca
commit df5de24b72
1 changed files with 13 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
lib/cdist/config_install.py
View file

@ -29,6 +29,8 @@ import sys
import cdist.emulator import cdist.emulator
import cdist.path import cdist.path
import cdist.core
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
CODE_HEADER = "#!/bin/sh -e\n" CODE_HEADER = "#!/bin/sh -e\n"
@ -108,14 +110,6 @@ class ConfigInstall:
cdist.emulator.link(self.exec_path, cdist.emulator.link(self.exec_path,
self.path.bin_dir, self.path.list_types()) self.path.bin_dir, self.path.list_types())
def init_deploy(self):
"""Ensure the base directories are cleaned up"""
log.debug("Creating clean directory structure")
self.path.remove_remote_dir(cdist.path.REMOTE_BASE_DIR)
self.path.remote_mkdir(cdist.path.REMOTE_BASE_DIR)
self.link_emulator()
def run_initial_manifest(self): def run_initial_manifest(self):
"""Run the initial manifest""" """Run the initial manifest"""
log.info("Running initial manifest %s", self.path.initial_manifest) log.info("Running initial manifest %s", self.path.initial_manifest)
@ -241,11 +235,11 @@ class ConfigInstall:
log.info("Running object manifests and type explorers") log.info("Running object manifests and type explorers")
old_objects = [] old_objects = []
objects = self.path.list_objects() objects = cdist.core.Object.list_objects()
# Continue process until no new objects are created anymore # Continue process until no new objects are created anymore
while old_objects != objects: while old_objects != objects:
old_objects = list(objects) old_objects = objects
for cdist_object in objects: for cdist_object in objects:
if cdist_object in self.objects_prepared: if cdist_object in self.objects_prepared:
log.debug("Skipping rerun of object %s", cdist_object) log.debug("Skipping rerun of object %s", cdist_object)
@ -255,7 +249,7 @@ class ConfigInstall:
self.run_type_manifest(cdist_object) self.run_type_manifest(cdist_object)
self.objects_prepared.append(cdist_object) self.objects_prepared.append(cdist_object)
objects = self.path.list_objects() objects = cdist.core.Object.list_objects()
def stage_run(self): def stage_run(self):
"""The final (and real) step of deployment""" """The final (and real) step of deployment"""
@ -285,3 +279,11 @@ class ConfigInstall:
self.deploy_to() self.deploy_to()
self.cleanup() self.cleanup()
### Cleaned / check functions: Round 1 :-) #################################
def init_deploy(self):
"""Ensure the base directories are cleaned up"""
log.debug("Creating clean directory structure")
self.path.remove_remote_dir(cdist.path.REMOTE_BASE_DIR)
self.path.remote_mkdir(cdist.path.REMOTE_BASE_DIR)
self.link_emulator()