WorkflowExecutionEvent.h
51 static std::shared_ptr<WorkflowExecutionEvent> waitForNextExecutionEvent(std::string, double timeout);
101 std::string toString() override { return "StandardJobCompletedEvent (job: " + this->standard_job->getName() + "; cs = " + this->compute_service->getName() + ")";}
139 std::string toString() override { return "StandardJobFailedEvent (job: " + this->standard_job->getName() + "; cs = " +
173 std::string toString() override { return "PilotJobStartedEvent (cs = " + this->compute_service->getName() + ")";}
205 std::string toString() override { return "PilotJobExpiredEvent (cs = " + this->compute_service->getName() + ")";}
A class to represent the various execution events that are relevant to the execution of a workflow...
Definition: WorkflowExecutionEvent.h:43
A "standard job has completed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:76
std::string toString() override
Get a textual description of the event.
Definition: WorkflowExecutionEvent.h:250
A "file copy has completed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:212
WorkflowFile * file
The workflow file that has successfully been copied.
Definition: WorkflowExecutionEvent.h:236
std::shared_ptr< FailureCause > failure_cause
The cause of the failure.
Definition: WorkflowExecutionEvent.h:291
std::shared_ptr< FileRegistryService > file_registry_service
The file registry service that was supposed to be updated (or nullptr if none)
Definition: WorkflowExecutionEvent.h:242
A "standard job has failed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:107
A "file copy has failed" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:262
std::string toString() override
Get a textual description of the event.
Definition: WorkflowExecutionEvent.h:205
A "pilot job has started" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:148
std::string toString() override
Get a textual description of the event.
Definition: WorkflowExecutionEvent.h:297
std::string toString() override
Get a textual description of the event.
Definition: WorkflowExecutionEvent.h:173
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:133
std::shared_ptr< ComputeService > compute_service
The compute service on which the pilot job has expired.
Definition: WorkflowExecutionEvent.h:199
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:129
std::string getName()
Get the job's name.
Definition: WorkflowJob.cpp:74
PilotJob * pilot_job
The pilot job that has expired.
Definition: WorkflowExecutionEvent.h:197
std::shared_ptr< FileLocation > dst
The destination location.
Definition: WorkflowExecutionEvent.h:289
std::string toString() override
Get a textual description of the event.
Definition: WorkflowExecutionEvent.h:139
std::shared_ptr< ComputeService > compute_service
The compute service on which the job has failed.
Definition: WorkflowExecutionEvent.h:131
StandardJob * standard_job
The standard job that has completed.
Definition: WorkflowExecutionEvent.h:93
A "timer went off" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:308
std::shared_ptr< ComputeService > compute_service
The compute service on which the pilot job has started.
Definition: WorkflowExecutionEvent.h:167
std::string toString() override
Get a textual description of the event.
Definition: WorkflowExecutionEvent.h:329
std::string toString() override
Get a textual description of the event.
Definition: WorkflowExecutionEvent.h:101
bool file_registry_service_updated
Whether the file registry service (if any) has been successfully updated.
Definition: WorkflowExecutionEvent.h:244
std::shared_ptr< FileLocation > src
The source location.
Definition: WorkflowExecutionEvent.h:287
std::shared_ptr< FileLocation > src
The source location.
Definition: WorkflowExecutionEvent.h:238
std::shared_ptr< ComputeService > compute_service
The compute service on which the standard job has completed.
Definition: WorkflowExecutionEvent.h:95
WorkflowFile * file
The workflow file that has failed to be copied.
Definition: WorkflowExecutionEvent.h:285
Definition: Alarm.cpp:19
A "pilot job has expired" WorkflowExecutionEvent.
Definition: WorkflowExecutionEvent.h:180
std::shared_ptr< FileLocation > dst
The destination location.
Definition: WorkflowExecutionEvent.h:240
PilotJob * pilot_job
The pilot job that has started.
Definition: WorkflowExecutionEvent.h:165