diff options
author | Matthias Beyer <matthias.beyer@atos.net> | 2021-09-15 10:23:12 +0200 |
---|---|---|
committer | Matthias Beyer <matthias.beyer@atos.net> | 2021-09-23 12:51:30 +0200 |
commit | b1137c967130715d68b40b332151d913be6ebbab (patch) | |
tree | 590d1a6250cd7e1933b85dc582087e0dbc9556f0 /src/orchestrator/orchestrator.rs | |
parent | 56a22ff903df0d881bce88bf68cdb4de8bab06c1 (diff) |
Add helper for displaying maps of errors
This patch adds a helper trait to display maps from UUID -> Error.
It is just introduced for convenience and less code duplication, the speed of
execution is not relevant at all in this case, as if this code is executed,
we're already handling errors and aborting the execution anyways.
Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>
Diffstat (limited to 'src/orchestrator/orchestrator.rs')
-rw-r--r-- | src/orchestrator/orchestrator.rs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs index 0f2e528..3493403 100644 --- a/src/orchestrator/orchestrator.rs +++ b/src/orchestrator/orchestrator.rs @@ -43,6 +43,7 @@ use crate::filestore::StagingStore; use crate::job::Dag; use crate::job::JobDefinition; use crate::job::RunnableJob; +use crate::orchestrator::util::*; use crate::source::SourceCache; use crate::util::EnvironmentVariableName; use crate::util::progress::ProgressBars; @@ -591,14 +592,14 @@ impl<'a> JobTask<'a> { // receive from the receiver let continue_receiving = self.perform_receive(&mut received_dependencies, &mut received_errors).await?; - trace!("[{}]: Received errors = {:?}", self.jobdef.job.uuid(), received_errors); + trace!("[{}]: Received errors = {}", self.jobdef.job.uuid(), received_errors.display_error_map()); // if there are any errors from child tasks if !received_errors.is_empty() { // send them to the parent,... // // We only send to one parent, because it doesn't matter // And we know that we have at least one sender - log::error!("[{}]: Received errors = {:?}", self.jobdef.job.uuid(), received_errors); + log::error!("[{}]: Received errors = {}", self.jobdef.job.uuid(), received_errors.display_error_map()); self.sender[0].send(Err(received_errors)).await; // ... and stop operation, because the whole tree will fail anyways. |