more hints on parallel running
Signed-off-by: Nico Schottelius <nico@kr.ethz.ch>
This commit is contained in:
parent
e07328f569
commit
5ba6e0bb14
2 changed files with 4 additions and 1 deletions
|
@ -618,10 +618,11 @@ if __name__ == "__main__":
|
||||||
process = {}
|
process = {}
|
||||||
time_start = datetime.datetime.now()
|
time_start = datetime.datetime.now()
|
||||||
try:
|
try:
|
||||||
|
log.info("Deploying to %s hosts", len(args.host))
|
||||||
for host in args.host:
|
for host in args.host:
|
||||||
c = Cdist(host, initial_manifest=args.manifest, home=args.cdist_home)
|
c = Cdist(host, initial_manifest=args.manifest, home=args.cdist_home)
|
||||||
if args.parallel:
|
if args.parallel:
|
||||||
log.info("Starting child process for %s", host)
|
log.debug("Starting child process for %s", host)
|
||||||
process[host] = multiprocessing.Process(target=c.deploy_and_cleanup)
|
process[host] = multiprocessing.Process(target=c.deploy_and_cleanup)
|
||||||
process[host].start()
|
process[host].start()
|
||||||
log.debug("After process for %s", host)
|
log.debug("After process for %s", host)
|
||||||
|
|
|
@ -1,4 +1,6 @@
|
||||||
- Remove all FIXME entries
|
- Remove all FIXME entries
|
||||||
|
- Support parallel execution
|
||||||
|
- and maximum number of parallel runs (-p X)
|
||||||
- Write cdist-manpage
|
- Write cdist-manpage
|
||||||
- Remove obsolete manpages
|
- Remove obsolete manpages
|
||||||
- Support different home instead of ../
|
- Support different home instead of ../
|
||||||
|
|
Loading…
Reference in a new issue