// start the workflow given in wf with the inputs give in wfInputs
// + then store the workflowToken into the toksArray
function startWorkflow(name, wf, wfInputs, toksArray)
{
System.log("Executing the workflow '" + wf.name + "' for ' " + name + "'");
var wfToken = wf.execute(wfInputs);
toksArray.push(wfToken);
}
// create the Properties map of workflow inputs
// These are defined in pairs - name and value
// Names must match the name of the input on the target workflow
// + the value type must match the expected type of the input
// You can modify this function to have as many as you need here, just follow the rules above
function createWorkflowInputs(inputName1, inputValue1)
{
// create the properties map to hold all the inputs
var wfInputs = new Properties();
// add all the inputs to the map in pairs
// NOTE: To add a third input, add the n/v pair to the parameter list above then
// put a line underneath here to add them to the inputs map
wfInputs.put(inputName1, inputValue1);
return wfInputs;
}
function monitorTokensToCompletion(toksArray)
{
System.log("Waiting for batch of " + toksArray.length + " workflows to complete....");
// use the OOTB action to wait for the batch to finish
// the return value here is the array of tokens
var completed = System.getModule("com.vmware.library.vc.basic").waitForCompletionForBatchWorkflow(toksArray);
// copy the completed tokens to the global token array
for each(var tok in toksArray)
{
wfTokens.push(tok);
}
System.log("Batch monitoring cycle completed!");
}
// Maximum concurrent workflows
var MAX_BATCH_SIZE = maxConcurrentWorkflows;
// we'll store the global results for all workflows we run here
wfTokens= [];
// keep the batch tokens in this array for now, they'll be copied over the global results later
// + we will reset this after that copy when a batch has completed
var batchTokens = [];
if(inputStrings != null && inputStrings.length > 0)
{
System.log("Starting workflows in batches of " + MAX_BATCH_SIZE + " for " + inputStrings.length + " inputs..");
for each (var inputString in inputStrings)
{
System.log("Next name is " + inputString);
// is there space in the current batch for a new entry?
if(batchTokens.length >= MAX_BATCH_SIZE)
{
// Current batch is full so wait for all of those workflows to complete
monitorTokensToCompletion(batchTokens);
// reset the batchTokens list now as we will start a new batch on the next loop
batchTokens = [];
}
// yes, we can add a new entry
// create the inputs
// NOTE: I've assumed that each VM is an input to the target workflow here just to show how that
// you can pass any object types to the function
// If you add new entries to the function parameter list then you need to modify this line to be sure
// that the inputs are correct for each workflow invocation
var workflowInputParams = createWorkflowInputs("inputValue", inputString);
// start the workflow and put the token into the batch list
startWorkflow(inputString, tWorkflow, workflowInputParams, batchTokens);
System.log("The workflow has started for input " + inputString);
}
// we've completed the list of input VMs - check if there is a partial batch of workflows still running
if(batchTokens.length > 0)
{
// wait for the last few workflows to complete
monitorTokensToCompletion(batchTokens);
}
}
System.log("Executed " + wfTokens.length + " total workflows...");
// Just printing vital bits here, you may want to change this to get better data
System.log("Name, Start Date, State, End Date");
for each(var wfTok in wfTokens)
{
System.log(wfTok.name + "," + wfTok.startDate + "," + wfTok.state + "," + wfTok.endDate);
}
