com.dtolabs.rundeck.core.execution.workflow

Class ParallelWorkflowExecutor

java.lang.Object

com.dtolabs.rundeck.core.execution.workflow.BaseWorkflowExecutor

com.dtolabs.rundeck.core.execution.workflow.ParallelWorkflowExecutor

All Implemented Interfaces:

WorkflowExecutor

Deprecated.

public class ParallelWorkflowExecutor
extends BaseWorkflowExecutor

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

Nested Class Summary

Nested classes/interfaces inherited from class com.dtolabs.rundeck.core.execution.workflow.BaseWorkflowExecutor

BaseWorkflowExecutor.StepResultCapture

Field Summary

Fields

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

Fields inherited from class com.dtolabs.rundeck.core.execution.workflow.BaseWorkflowExecutor

OPTION_KEY, SECURE_OPTION_KEY, SECURE_OPTION_VALUE

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

NODE_FIRST, PARALLEL, STEP_FIRST

Constructor Summary

Constructors

Constructor and Description
ParallelWorkflowExecutor(Framework framework) Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
WorkflowExecutionResult	executeWorkflowImpl(StepExecutionContext executionContext, WorkflowExecutionItem item) Deprecated.
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) Deprecated. 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.BaseWorkflowExecutor

addNodeStepFailureContextData, addStepFailureContextData, convertFailures, createPrintableDataContext, createPrintableDataContext, executeWFItem, executeWorkflow, executeWorkflowItemsForNodeSet, executeWorkflowItemsForNodeSet, executeWorkflowStep, executeWorkflowStep, 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

Deprecated.

See Also:

Constant Field Values

Constructor Detail

ParallelWorkflowExecutor

public ParallelWorkflowExecutor(Framework framework)

Deprecated.

Method Detail

executeWorkflowImpl

public WorkflowExecutionResult executeWorkflowImpl(StepExecutionContext executionContext,
                                          WorkflowExecutionItem item)

Deprecated.

Specified by:

executeWorkflowImpl in class BaseWorkflowExecutor

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)

Deprecated.

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