WorkflowExecutionEvent.h
A class to represent the various execution events that are relevant to the execution of a workflow...
Definition: WorkflowExecutionEvent.h:43
WorkflowExecutionEvent::EventType type
The event type.
Definition: WorkflowExecutionEvent.h:66
A "standard job has completed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:93
A "file copy has completed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:205
WorkflowFile * file
The workflow file that has successfully been copied.
Definition: WorkflowExecutionEvent.h:228
std::shared_ptr< FailureCause > failure_cause
The cause of the failure.
Definition: WorkflowExecutionEvent.h:267
A "standard job has failed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:119
A "file copy has failed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:241
StorageService * storage_service
The storage service on which it was supposed to be copied.
Definition: WorkflowExecutionEvent.h:265
ComputeService * compute_service
The compute service on which the job has failed.
Definition: WorkflowExecutionEvent.h:144
ComputeService * compute_service
The compute service on which the pilot job has expired.
Definition: WorkflowExecutionEvent.h:199
A "pilot job has started" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:153
A data file used/produced by a WorkflowTask in a Workflow.
Definition: WorkflowFile.h:26
std::shared_ptr< FailureCause > failure_cause
The cause of the failure.
Definition: WorkflowExecutionEvent.h:146
ComputeService * compute_service
The compute service on which the pilot job has started.
Definition: WorkflowExecutionEvent.h:173
static std::unique_ptr< WorkflowExecutionEvent > waitForNextExecutionEvent(std::string)
Block the calling process until a WorkflowExecutionEvent is generated based on messages received on a...
Definition: WorkflowExecutionEvent.cpp:36
A file copy operation completed.
Definition: WorkflowExecutionEvent.h:60
A pilot (i.e., non-standard) workflow job that can be submitted to a ComputeService by a WMS (via a J...
Definition: PilotJob.h:29
A standard (i.e., non-pilot) workflow job that can be submitted to a ComputeService by a WMS (via a J...
Definition: StandardJob.h:38
StandardJob * standard_job
The standard job that has failed.
Definition: WorkflowExecutionEvent.h:142
PilotJob * pilot_job
The pilot job that has expired.
Definition: WorkflowExecutionEvent.h:197
StorageService * storage_service
The storage service to which the file has been copied.
Definition: WorkflowExecutionEvent.h:230
A standard job failed.
Definition: WorkflowExecutionEvent.h:54
StandardJob * standard_job
The standard job that has completed.
Definition: WorkflowExecutionEvent.h:111
A standard job successfully completed.
Definition: WorkflowExecutionEvent.h:52
A file registry service (a.k.a. replica catalog) that holds a database of which files are available a...
Definition: FileRegistryService.h:33
ComputeService * compute_service
The compute service on which the standard job has completed.
Definition: WorkflowExecutionEvent.h:113
A file copy operation failed.
Definition: WorkflowExecutionEvent.h:62
EventType
Workflow execution event types.
Definition: WorkflowExecutionEvent.h:48
A pilot job expired.
Definition: WorkflowExecutionEvent.h:58
A pilot job started.
Definition: WorkflowExecutionEvent.h:56
bool file_registry_service_updated
Whether the file registry service (if any) has been successfully updated.
Definition: WorkflowExecutionEvent.h:234
WorkflowFile * file
The workflow file that has failed to be copied.
Definition: WorkflowExecutionEvent.h:263
Definition: TerminalOutput.cpp:15
A "pilot job has expired" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:179
WorkflowExecutionEvent(EventType type)
Constructor.
Definition: WorkflowExecutionEvent.h:82
FileRegistryService * file_registry_service
The file registry service that was supposed to be updated (or nullptr if none)
Definition: WorkflowExecutionEvent.h:232
PilotJob * pilot_job
The pilot job that has started.
Definition: WorkflowExecutionEvent.h:171