Enabling passing kwargs to runSaltProcessStep func
Change-Id: I5be1fe18b4ddce0f3bb2427fd6d97827ace8b6b0
diff --git a/src/com/mirantis/mk/Salt.groovy b/src/com/mirantis/mk/Salt.groovy
index 71657d6..755dcd5 100644
--- a/src/com/mirantis/mk/Salt.groovy
+++ b/src/com/mirantis/mk/Salt.groovy
@@ -460,7 +460,7 @@
* @param timeout Additional argument salt api timeout
* @return output of salt command
*/
-def runSaltProcessStep(master, tgt, fun, arg = [], batch = null, output = false, timeout = -1) {
+def runSaltProcessStep(master, tgt, fun, arg = [], batch = null, output = false, timeout = -1, kwargs = null) {
def common = new com.mirantis.mk.Common()
def salt = new com.mirantis.mk.Salt()
def out
@@ -468,9 +468,9 @@
common.infoMsg("Running step ${fun} ${arg} on ${tgt}")
if (batch == true) {
- out = runSaltCommand(master, 'local_batch', ['expression': tgt, 'type': 'compound'], fun, String.valueOf(batch), arg, null, timeout)
+ out = runSaltCommand(master, 'local_batch', ['expression': tgt, 'type': 'compound'], fun, String.valueOf(batch), arg, kwargs, timeout)
} else {
- out = runSaltCommand(master, 'local', ['expression': tgt, 'type': 'compound'], fun, batch, arg, null, timeout)
+ out = runSaltCommand(master, 'local', ['expression': tgt, 'type': 'compound'], fun, batch, arg, kwargs, timeout)
}
if (output == true) {