com.dtolabs.rundeck.core.execution.workflow

Class ParallelWorkflowStrategy

java.lang.Object

com.dtolabs.rundeck.core.execution.workflow.BaseWorkflowStrategy

com.dtolabs.rundeck.core.execution.workflow.ParallelWorkflowStrategy

All Implemented Interfaces:

WorkflowExecutor, WorkflowStrategy

public class ParallelWorkflowStrategy
extends BaseWorkflowStrategy

ParallelWorkflowStrategy dispatches all steps in parallel to all nodes they are configured to run and waits for their completion before terminating. Failure of 'any' sub-steps results in failure of the workflow regardless of keep-going TODO: parallel execution can be extended into and_parallel, or_parallel, xor_parallel, .. based on how failures are handled TODO: Discuss and implement 'aborting' ongoing parallel steps if any of parallel steps fail beforehand and keep_going == false
The WorkflowExecutionResult will contain as the resultSet a map of Node name to list of step execution results on that node

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	DATA_CONTEXT_PREFIX

Fields inherited from interface com.dtolabs.rundeck.core.execution.workflow.WorkflowStrategy

NODE_FIRST, PARALLEL, STEP_FIRST

Constructor Summary

Constructors

Constructor and Description
ParallelWorkflowStrategy(Framework framework)

Method Summary

Methods

Modifier and Type	Method and Description
WorkflowExecutionResult	executeWorkflowImpl(StepExecutionContext executionContext, WorkflowExecutionItem item)
protected WorkflowStatusResult	executeWorkflowItemsInParallel(StepExecutionContext executionContext, java.util.Map<java.lang.Integer,StepExecutionResult> failedMap, java.util.List<StepExecutionResult> resultList, java.util.List<StepExecutionItem> iWorkflowCmdItems, boolean keepgoing) Execute the sequence of ExecutionItems within the context, and with the given keepgoing value, return true if successful

Methods inherited from class com.dtolabs.rundeck.core.execution.workflow.BaseWorkflowStrategy

addNodeStepFailureContextData, addStepFailureContextData, convertFailures, createPrintableDataContext, executeWFItem, executeWorkflow, executeWorkflowItemsForNodeSet, executeWorkflowItemsForNodeSet, getWorkflowListener, nodeStepResultFromNodeStepException, replaceFailedNodesListenerInContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DATA_CONTEXT_PREFIX

protected static final java.lang.String DATA_CONTEXT_PREFIX

See Also:

Constant Field Values

Constructor Detail

ParallelWorkflowStrategy

public ParallelWorkflowStrategy(Framework framework)

Method Detail

executeWorkflowImpl

public WorkflowExecutionResult executeWorkflowImpl(StepExecutionContext executionContext,
                                          WorkflowExecutionItem item)

Specified by:

executeWorkflowImpl in class BaseWorkflowStrategy

executeWorkflowItemsInParallel

protected WorkflowStatusResult executeWorkflowItemsInParallel(StepExecutionContext executionContext,
                                                  java.util.Map<java.lang.Integer,StepExecutionResult> failedMap,
                                                  java.util.List<StepExecutionResult> resultList,
                                                  java.util.List<StepExecutionItem> iWorkflowCmdItems,
                                                  boolean keepgoing)

Execute the sequence of ExecutionItems within the context, and with the given keepgoing value, return true if successful

Parameters:

executionContext - context

failedMap - failures

resultList - results

iWorkflowCmdItems - steps

keepgoing - true to keepgoing if a step fails

Returns:

true if successful