v0.3.11-pre.009-fix.003

This commit is contained in:
2026-09-08 16:58:15 +02:00
parent 637382f364
commit d231eba8be
3 changed files with 101 additions and 3 deletions

View File

@@ -1,5 +1,5 @@
// file: crates/ksp-worker-raw-transaction-ingest-lib/unit_tests/runtime.rs
// version: 8
// version: 9
struct ActiveTaskGuard {
active: std::sync::Arc<std::sync::atomic::AtomicUsize>,
@@ -683,7 +683,9 @@ async fn pre_009_source_failure_is_counted_and_late_stop_cannot_replace_terminal
tokio::runtime::Handle::current(),
std::option::Option::None,
move |children: &mut tokio::task::JoinSet<ksp_core_lib::Result<()>>, _stop_receiver, _admission_sender| {
let _abort_handle = children.spawn(async move { std::result::Result::Err(crate::runtime_error("test.source_failed")) });
let _abort_handle = children.spawn(async move {
return std::result::Result::Err(crate::runtime_error("test.source_failed"));
});
},
) {
std::result::Result::Ok(value) => value,