Remove unnecessary fuse

node/core/pvf/src/execute/worker.rs

@@ -250,22 +250,18 @@ pub fn worker_entrypoint(socket_path: &str) {
 
 			// Spawn a new thread that runs the CPU time monitor.
 			let finished_flag_2 = finished_flag.clone();
-			let thread_fut = rt_handle
-				.spawn_blocking(move || {
-					cpu_time_monitor_loop(
-						JobKind::Execute,
-						cpu_time_start,
-						execution_timeout,
-						finished_flag_2,
-					);
-				})
-				.fuse();
+			let thread_fut = rt_handle.spawn_blocking(move || {
+				cpu_time_monitor_loop(
+					JobKind::Execute,
+					cpu_time_start,
+					execution_timeout,
+					finished_flag_2,
+				);
+			});
 			let executor_2 = executor.clone();
-			let execute_fut = rt_handle
-				.spawn_blocking(move || {
-					validate_using_artifact(&artifact_path, &params, executor_2, cpu_time_start)
-				})
-				.fuse();
+			let execute_fut = rt_handle.spawn_blocking(move || {
+				validate_using_artifact(&artifact_path, &params, executor_2, cpu_time_start)
+			});
 
 			let response = select! {
 				// If this future is not selected, the join handle is dropped and the thread will

node/core/pvf/src/prepare/worker.rs

@@ -25,7 +25,6 @@ use crate::{
 	LOG_TARGET,
 };
 use cpu_time::ProcessTime;
-use futures::FutureExt;
 use parity_scale_codec::{Decode, Encode};
 use sp_core::hexdisplay::HexDisplay;
 use std::{
@@ -325,17 +324,15 @@ pub fn worker_entrypoint(socket_path: &str) {
 
 			// Spawn a new thread that runs the CPU time monitor.
 			let finished_flag_2 = finished_flag.clone();
-			let thread_fut = rt_handle
-				.spawn_blocking(move || {
-					cpu_time_monitor_loop(
-						JobKind::Prepare,
-						cpu_time_start,
-						preparation_timeout,
-						finished_flag_2,
-					)
-				})
-				.fuse();
-			let prepare_fut = rt_handle.spawn_blocking(move || prepare_artifact(&code)).fuse();
+			let thread_fut = rt_handle.spawn_blocking(move || {
+				cpu_time_monitor_loop(
+					JobKind::Prepare,
+					cpu_time_start,
+					preparation_timeout,
+					finished_flag_2,
+				)
+			});
+			let prepare_fut = rt_handle.spawn_blocking(move || prepare_artifact(&code));
 
 			let result = select! {
 				// If this future is not selected, the join handle is dropped and the thread will