diff options
Diffstat (limited to 'crates/core/tedge_core/src/reactor.rs')
| -rw-r--r-- | crates/core/tedge_core/src/reactor.rs | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/crates/core/tedge_core/src/reactor.rs b/crates/core/tedge_core/src/reactor.rs index 3c4e6a91..21252537 100644 --- a/crates/core/tedge_core/src/reactor.rs +++ b/crates/core/tedge_core/src/reactor.rs @@ -218,7 +218,7 @@ impl Reactor { .await; debug!("Running 'main' for plugins"); - let _main_results = all_plugins + let (_main_results_ok, main_results_err): (Vec<_>, Vec<_>) = all_plugins .iter_mut() .map(|plugin_task| { let span = @@ -228,7 +228,15 @@ impl Reactor { .collect::<futures::stream::FuturesUnordered<_>>() .collect::<Vec<Result<(), _>>>() .instrument(tracing::info_span!("core.mainloop.plugins.main")) - .await; + .await + .into_iter() + .partition_result(); + + if !main_results_err.is_empty() { + return Err(TedgeApplicationError::PluginLifecycleErrors { + errors: main_results_err, + }); + } // And now we wait until all communication is finished. // |