The remote execution function
(*args, **kwargs)
| 232 | return self.aliases[cmd] |
| 233 | |
| 234 | def caller(*args, **kwargs): |
| 235 | """ |
| 236 | The remote execution function |
| 237 | """ |
| 238 | argv = [cmd] |
| 239 | argv.extend([salt.utils.json.dumps(arg) for arg in args]) |
| 240 | argv.extend( |
| 241 | [ |
| 242 | "{}={}".format( |
| 243 | salt.utils.stringutils.to_str(key), salt.utils.json.dumps(val) |
| 244 | ) |
| 245 | for key, val in kwargs.items() |
| 246 | ] |
| 247 | ) |
| 248 | single = salt.client.ssh.Single( |
| 249 | self.opts, |
| 250 | argv, |
| 251 | mods=self.mods, |
| 252 | disable_wipe=True, |
| 253 | fsclient=self.fsclient, |
| 254 | minion_opts=self.minion_opts, |
| 255 | **self.kwargs, |
| 256 | ) |
| 257 | stdout, stderr, retcode = single.cmd_block() |
| 258 | return parse_ret(stdout, stderr, retcode, result_only=True) |
| 259 | |
| 260 | return caller |
| 261 |