summaryrefslogtreecommitdiffstats
path: root/src/orchestrator/orchestrator.rs
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@atos.net>2021-09-15 10:23:12 +0200
committerMatthias Beyer <matthias.beyer@atos.net>2021-09-23 12:51:30 +0200
commitb1137c967130715d68b40b332151d913be6ebbab (patch)
tree590d1a6250cd7e1933b85dc582087e0dbc9556f0 /src/orchestrator/orchestrator.rs
parent56a22ff903df0d881bce88bf68cdb4de8bab06c1 (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.rs5
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.