public class LocalExecution extends AbstractExecution implements ResultListener
Execution
for
executing Taverna workflows on a local Taverna Dataflow Engine.Constructor and Description |
---|
LocalExecution(WorkflowBundle workflowBundle,
Workflow workflow,
Profile profile,
Bundle dataBundle,
ReferenceService referenceService,
Edits edits,
ActivityService activityService,
DispatchLayerService dispatchLayerService)
Constructs an Execution for executing Taverna workflows on a local
Taverna Dataflow Engine.
|
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancels the execution.
|
ActivityReport |
createActivityReport(Activity activity) |
ProcessorReport |
createProcessorReport(Processor processor) |
protected WorkflowReport |
createWorkflowReport(Workflow workflow) |
void |
delete()
Deletes the execution.
|
void |
pause()
Pauses the execution.
|
void |
resultTokenProduced(WorkflowDataToken token,
String portName)
Called when a new result token is produced by the workflow instance.
|
void |
resume()
Resumes a paused execution.
|
void |
start()
Starts the execution.
|
generateWorkflowReport, getDataBundle, getID, getProfile, getWorkflow, getWorkflowBundle, getWorkflowReport
public LocalExecution(WorkflowBundle workflowBundle, Workflow workflow, Profile profile, Bundle dataBundle, ReferenceService referenceService, Edits edits, ActivityService activityService, DispatchLayerService dispatchLayerService) throws InvalidWorkflowException
workflowBundle
- the WorkflowBundle
containing the
Workflow
s required for executionworkflow
- the Workflow
to executeprofile
- the Profile
to use when executing the
Workflow
dataBundle
- the Bundle
containing the data values for the
Workflow
referenceService
- the ReferenceService
used to register inputs,
outputs and intermediate valuesInvalidWorkflowException
- if the specified workflow is invalidpublic void delete()
Execution
public void start()
Execution
public void pause()
Execution
public void resume()
Execution
public void cancel()
Execution
protected WorkflowReport createWorkflowReport(Workflow workflow)
createWorkflowReport
in class AbstractExecution
public ProcessorReport createProcessorReport(Processor processor)
createProcessorReport
in class AbstractExecution
public ActivityReport createActivityReport(Activity activity)
createActivityReport
in class AbstractExecution
public void resultTokenProduced(WorkflowDataToken token, String portName)
ResultListener
resultTokenProduced
in interface ResultListener
token
- the WorkflowDataToken containing the result.portName
- The name of the output port on the workflow from which this
token is produced, this now folds in the owning process which
was part of the signature for this methodCopyright © 2015–2016 The Apache Software Foundation. All rights reserved.