diff --git a/core/node/vm_runner/src/process.rs b/core/node/vm_runner/src/process.rs index 5e51b5e658f7..2d992fdd31dc 100644 --- a/core/node/vm_runner/src/process.rs +++ b/core/node/vm_runner/src/process.rs @@ -134,6 +134,11 @@ impl VmRunner { .await? + 1; loop { + if *stop_receiver.borrow() { + tracing::info!("VM runner was interrupted"); + return Ok(()); + } + // Traverse all handles and filter out tasks that have been finished. Also propagates // any panic/error that might have happened during the task's execution. let mut retained_handles = Vec::new();