diff --git a/cumulus/consensus/src/lib.rs b/cumulus/consensus/src/lib.rs
index 97d3111564..5e9776b471 100644
--- a/cumulus/consensus/src/lib.rs
+++ b/cumulus/consensus/src/lib.rs
@@ -98,10 +98,9 @@ pub fn follow_polkadot<L, P>(para_id: ParaId, local: Arc<L>, polkadot: P)
 
 		finalized_heads
 			.map(|head_data| {
-				<Option<<L::Block as BlockT>::Header>>::decode(&mut &head_data[..])
+				<<L::Block as BlockT>::Header>::decode(&mut &head_data[..])
 					.map_err(|_| Error::InvalidHeadData)
 			})
-			.try_filter_map(|h| future::ready(Ok(h)))
 			.try_for_each(move |p_head| {
 				future::ready(local.finalize(p_head.hash()).map_err(Error::Client).map(|_| ()))
 			})