in container_agent/run_containers.py [0:0]
def RunContainersFromConfigFiles(config_glob, reload_interval, namespace):
while True:
try:
files = glob(config_glob)
log.debug('loading config files: %s', files)
containers = []
volumes = {}
for filename in files:
with open(filename) as f:
file_config = yaml.load(f)
containers.extend(file_config.get('containers', []))
volumes.update(file_config.get('volumes', {}))
all_volumes = LoadVolumes(volumes)
user_containers = LoadUserContainers(containers, all_volumes)
CheckGroupWideConflicts(user_containers)
RunContainers(user_containers, namespace)
except Exception:
log.exception("exception")
log.debug('sleeping %d seconds', reload_interval)
time.sleep(float(reload_interval))