Execute salt-run
(
self,
arg_str,
with_retcode=False,
catch_stderr=False,
asynchronous=False,
timeout=None,
config_dir=None,
**kwargs,
)
| 134 | return ret |
| 135 | |
| 136 | def run_run( |
| 137 | self, |
| 138 | arg_str, |
| 139 | with_retcode=False, |
| 140 | catch_stderr=False, |
| 141 | asynchronous=False, |
| 142 | timeout=None, |
| 143 | config_dir=None, |
| 144 | **kwargs, |
| 145 | ): |
| 146 | """ |
| 147 | Execute salt-run |
| 148 | """ |
| 149 | if timeout is None: |
| 150 | timeout = self.RUN_TIMEOUT |
| 151 | asynchronous = kwargs.get("async", asynchronous) |
| 152 | arg_str = "{async_flag} -t {timeout} {}".format( |
| 153 | arg_str, |
| 154 | timeout=timeout, |
| 155 | async_flag=" --async" if asynchronous else "", |
| 156 | ) |
| 157 | ret = self.run_script( |
| 158 | "salt-run", |
| 159 | arg_str, |
| 160 | with_retcode=with_retcode, |
| 161 | catch_stderr=catch_stderr, |
| 162 | timeout=timeout, |
| 163 | config_dir=config_dir, |
| 164 | ) |
| 165 | log.debug("Result of run_run for command '%s': %s", arg_str, ret) |
| 166 | return ret |
| 167 | |
| 168 | def run_run_plus(self, fun, *arg, **kwargs): |
| 169 | """ |
nothing calls this directly
no test coverage detected