rebase issues

client/network/src/lib.rs

@@ -453,20 +453,35 @@ async fn wait_to_announce<Block: BlockT>(
 	}
 }
 
-#[derive(Clone)]
-pub struct WaitForParachainTargetBlock<Block> {
-	phantom: PhantomData<Block>,
-}
-
 pub async fn warp_sync_get<B>(
 	para_id: ParaId,
 	relay_chain_interface: Arc<dyn RelayChainInterface>,
+	spawner: Arc<dyn SpawnNamed + Send + Sync>,
 ) -> Result<oneshot::Receiver<<B as BlockT>::Header>, BoxedError>
 where
 	B: BlockT + 'static,
 {
 	let (sender, receiver) = oneshot::channel::<B::Header>();
-	wait_for_target_block::<B>(sender, para_id, relay_chain_interface).await?;
+	spawner.spawn(
+		"cumulus-parachain-wait-for-target-block",
+		None,
+		async move {
+			tracing::debug!(
+				target: "cumulus-network",
+				"waiting for announce block in a background task...",
+			);
+			tracing::debug!(target: LOG_TARGET, "waiting for target block in a background task...",);
+			wait_for_target_block::<B>(sender, para_id, relay_chain_interface)
+				.await
+				.map_err(|e| {
+					tracing::error!(target: LOG_TARGET, "Unable to determine sync status. {}", e)
+				})
+				.unwrap();
+			tracing::debug!(target: LOG_TARGET, "target block reached",);
+		}
+		.boxed(),
+	);
+
 	return Ok(receiver)
 }
 

client/service/src/lib.rs

@@ -286,6 +286,7 @@ where
 	let warp_sync_params = if let Ok(target_block) = cumulus_client_network::warp_sync_get::<Block>(
 		para_id,
 		Arc::new(relay_chain_interface.clone()),
+		Arc::new(task_manager.spawn_handle()),
 	)
 	.await
 	{