Method add_process

salt/utils/process.py:524–561

Create a processes and args + kwargs This will deterimine if it is a Process class, otherwise it assumes it is a function

(self, tgt, args=None, kwargs=None, name=None)

        self._restart_processes = True

    def add_process(self, tgt, args=None, kwargs=None, name=None):
        """
        Create a processes and args + kwargs
        This will deterimine if it is a Process class, otherwise it assumes
        it is a function
        """
        if args is None:
            args = []
        if kwargs is None:
            kwargs = {}

        if inspect.isclass(tgt) and issubclass(tgt, multiprocessing.Process):
            if name is None:
                name = getattr(tgt, "__qualname__", str(tgt))
            kwargs["name"] = name
            process = tgt(*args, **kwargs)
        else:
            if name is None:
                name = getattr(tgt, "__qualname__", str(tgt))
            process = Process(target=tgt, args=args, kwargs=kwargs, name=name)

        process.register_finalize_method(cleanup_finalize_process, args, kwargs)

        if isinstance(process, SignalHandlingProcess):
            with default_signals(signal.SIGINT, signal.SIGTERM):
                process.start()
        else:
            process.start()

        log.debug("Started '%s' with pid %s", process.name, process.pid)
        self._process_map[process.pid] = {
            "tgt": tgt,
            "args": args,
            "kwargs": kwargs,
            "Process": process,
        }

        return process

    def restart_process(self, pid):
        """