Method run

tools/tasks.py:322–355

Run a task with a file descriptor corresponding to its log file

(self, task)

            log("Exit code %d" % result)

    def run(self, task):
        """Run a task with a file descriptor corresponding to its log file"""
        command_to_print = getattr(task, "command_to_print", task.command)
        if task.will_run():
            log("%s (%s) - " % (task.description, command_to_print), end="")
            if task.privileged and os.getuid() != 0:
                log("skipped (needs root privs)")
                return

            if hasattr(task, "log_file"):
                filename = task.log_file
            else:
                filename = self.default_name

            fp = self.get_file(filename)
            if not task.no_header:
                self.header(fp, task.description, command_to_print)

            for i in range(task.num_samples):
                if i > 0:
                    log(
                        "Taking sample %d after %f seconds - " % (i + 1, task.interval),
                        end="",
                    )
                    time.sleep(task.interval)
                result = task.execute(fp)
                self.log_result(result)
            fp.flush()

        elif self.verbosity >= 2:
            log(
                'Skipping "%s" (%s): not for platform %s'
                % (task.description, command_to_print, sys.platform)
            )

    def redact_and_zip(self, filename: str, log_type: str, salt: str, node: str):
        """