org.kepler.workflowrunmanager

Class WorkflowRunManagerRecording

java.lang.Object

org.kepler.provenance.Recording

org.kepler.workflowrunmanager.WorkflowRunManagerRecording

public class WorkflowRunManagerRecording
extends Recording

Receive provenance events and update the WorkflowRunManager GUI.

Author:

Daniel Crawl

Field Summary

Fields inherited from class org.kepler.provenance.Recording

_containerFullName, _containerLSID, _containerName, _debugPrint, _debugWriter, _machineStr, _recorder, _recorderContainer, _stateSerializer

Constructor Summary

Constructors

Constructor and Description
WorkflowRunManagerRecording(WorkflowRunManager manager) Construct a new WorkflowRunManagerRecording.

Method Summary

Modifier and Type	Method and Description
void	executionError(Nameable source, java.lang.Throwable throwable, KeplerLSID execLSID) update WRM table after an execution gives an error.
void	executionImported(KeplerLSID execLSID) update WRM table after an execution has been imported.
void	executionStart(KeplerLSID execLSID) update WRM table to see a run as it's running.
void	executionStop(KeplerLSID execLSID) update WRM table after an execution finishes.
void	renamedWorkflow(NamedObj namedObj, KeplerLSID oldLSID, KeplerLSID newLSID, java.lang.String oldName, java.lang.String newName) A workflow was renamed.
void	tagAdded(TagEvent event) update WRM table after a run tag has been added.
void	tagRemoved(TagEvent event) update WRM table after a run tag has been removed.

Methods inherited from class org.kepler.provenance.Recording

_debug, _debug, _debugWrite, _debugWrite, _error, _getExceptionMessage, _getNameableFullName, _needWorkflowContents, _updateContainerName, _warn, actorFire, actorFire, addFileForLastExecution, attributeChanged, changeExecutionLSID, customProvEvent, disconnect, evolutionStart, evolutionStop, executionError, executionImported, executionStart, executionStart, executionStart, executionStop, executionStop, executionStop, generateParameters, getContainer, getQueryable, portEvent, portEvent, refillPortEvent, regActor, regContents, regDirector, regLink, regParameter, regPort, regRelation, remove, removeLink, removeStateSerializer, rename, setContainer, setContainerLSID, setContainerName, setDebugWriter, setStateSerializer, specificationStart, specificationStop

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkflowRunManagerRecording

public WorkflowRunManagerRecording(WorkflowRunManager manager)
                            throws RecordingException

Construct a new WorkflowRunManagerRecording.

Throws:

RecordingException

Method Detail

renamedWorkflow

public void renamedWorkflow(NamedObj namedObj,
                            KeplerLSID oldLSID,
                            KeplerLSID newLSID,
                            java.lang.String oldName,
                            java.lang.String newName)

A workflow was renamed.

Overrides:

renamedWorkflow in class Recording

Parameters:

namedObj - the workflow

oldLSID - the previous LSID

newLSID - the new lsid

oldName - the previous name

newName - the new name

See Also:

WorkflowRenameListener

executionStart

public void executionStart(KeplerLSID execLSID)

update WRM table to see a run as it's running.

Overrides:

executionStart in class Recording

executionError

public void executionError(Nameable source,
                           java.lang.Throwable throwable,
                           KeplerLSID execLSID)
                    throws RecordingException

update WRM table after an execution gives an error.

Overrides:

executionError in class Recording

Throws:

RecordingException

executionStop

public void executionStop(KeplerLSID execLSID)

update WRM table after an execution finishes.

Overrides:

executionStop in class Recording

executionImported

public void executionImported(KeplerLSID execLSID)

update WRM table after an execution has been imported.

Overrides:

executionImported in class Recording

tagAdded

public void tagAdded(TagEvent event)
              throws RecordingException

update WRM table after a run tag has been added.

Overrides:

tagAdded in class Recording

Throws:

RecordingException

tagRemoved

public void tagRemoved(TagEvent event)
                throws RecordingException

update WRM table after a run tag has been removed.

Overrides:

tagRemoved in class Recording

Throws:

RecordingException