diff --git a/cdist/core/explorer.py b/cdist/core/explorer.py index efffb6ed..17d6f46e 100644 --- a/cdist/core/explorer.py +++ b/cdist/core/explorer.py @@ -117,19 +117,19 @@ class Explorer(object): self.jobs)) self.log.debug("Multiprocessing start method is {}".format( multiprocessing.get_start_method())) - self.log.info(("Starting multiprocessing Pool for global " + self.log.debug(("Starting multiprocessing Pool for global " "explorers run")) with multiprocessing.Pool(self.jobs) as pool: - self.log.info("Starting async for global explorer run") + self.log.debug("Starting async for global explorer run") results = [ pool.apply_async(self._run_global_explorer, (e, out_path,)) for e in self.list_global_explorer_names() ] - self.log.info("Waiting async results for global explorer runs") + self.log.debug("Waiting async results for global explorer runs") for r in results: r.get() # self._run_global_explorer returns None - self.log.info(("Multiprocessing run for global explorers " + self.log.debug(("Multiprocessing run for global explorers " "finished")) # logger is not pickable, so remove it when we pickle diff --git a/cdist/exec/remote.py b/cdist/exec/remote.py index 389c0da1..72dc5840 100644 --- a/cdist/exec/remote.py +++ b/cdist/exec/remote.py @@ -136,10 +136,10 @@ class Remote(object): jobs)) self.log.debug("Multiprocessing start method is {}".format( multiprocessing.get_start_method())) - self.log.info(("Starting multiprocessing Pool for parallel " + self.log.debug(("Starting multiprocessing Pool for parallel " "remote transfer")) with multiprocessing.Pool(jobs) as pool: - self.log.info("Starting async for parallel transfer") + self.log.debug("Starting async for parallel transfer") commands = [] for f in glob.glob1(source, '*'): command = self._copy.split() @@ -152,10 +152,10 @@ class Remote(object): for cmd in commands ] - self.log.info("Waiting async results for parallel transfer") + self.log.debug("Waiting async results for parallel transfer") for r in results: r.get() # self._run_command returns None - self.log.info(("Multiprocessing for parallel transfer " + self.log.debug(("Multiprocessing for parallel transfer " "finished")) else: raise cdist.Error("Source {} is not a directory".format(source))