[stable2506] Backport #9581 (#9634)

Backport #9581 into `stable2506` from sistemd.

See the
[documentation](https://github.com/paritytech/polkadot-sdk/blob/master/docs/BACKPORT.md)
on how to use this bot.

<!--
  # To be used by other automation, do not modify:
  original-pr-number: #${pull_number}
-->

Co-authored-by: sistemd <[email protected]>
Co-authored-by: cmd[bot] <41898282+github-actions[bot]@users.noreply.github.com>
Co-authored-by: Bastian Köcher <[email protected]>

Author: 4 people

cumulus/client/service/src/lib.rs

@@ -302,6 +302,7 @@ where
 		.spawn("cumulus-pov-recovery", None, pov_recovery.run());
 
 	let parachain_informant = parachain_informant::<Block, _>(
+		para_id,
 		relay_chain_interface.clone(),
 		client.clone(),
 		prometheus_registry.map(ParachainInformantMetrics::new).transpose()?,
@@ -609,6 +610,7 @@ where
 
 /// Task for logging candidate events and some related metrics.
 async fn parachain_informant<Block: BlockT, Client>(
+	para_id: ParaId,
 	relay_chain_interface: impl RelayChainInterface + Clone,
 	client: Arc<Client>,
 	metrics: Option<ParachainInformantMetrics>,
@@ -636,7 +638,10 @@ async fn parachain_informant<Block: BlockT, Client>(
 		let mut timed_out_candidates = Vec::new();
 		for event in candidate_events {
 			match event {
-				CandidateEvent::CandidateBacked(_, head, _, _) => {
+				CandidateEvent::CandidateBacked(receipt, head, _, _) => {
+					if receipt.descriptor.para_id() != para_id {
+						continue;
+					}
 					let backed_block = match Block::Header::decode(&mut &head.0[..]) {
 						Ok(header) => header,
 						Err(e) => {
@@ -656,7 +661,10 @@ async fn parachain_informant<Block: BlockT, Client>(
 					last_backed_block_time = Some(backed_block_time);
 					backed_candidates.push(backed_block);
 				},
-				CandidateEvent::CandidateIncluded(_, head, _, _) => {
+				CandidateEvent::CandidateIncluded(receipt, head, _, _) => {
+					if receipt.descriptor.para_id() != para_id {
+						continue;
+					}
 					let included_block = match Block::Header::decode(&mut &head.0[..]) {
 						Ok(header) => header,
 						Err(e) => {
@@ -674,7 +682,10 @@ async fn parachain_informant<Block: BlockT, Client>(
 					}
 					included_candidates.push(included_block);
 				},
-				CandidateEvent::CandidateTimedOut(_, head, _) => {
+				CandidateEvent::CandidateTimedOut(receipt, head, _) => {
+					if receipt.descriptor.para_id() != para_id {
+						continue;
+					}
 					let timed_out_block = match Block::Header::decode(&mut &head.0[..]) {
 						Ok(header) => header,
 						Err(e) => {

prdoc/pr_9581.prdoc

@@ -0,0 +1,8 @@
+title: 'fix: parachain informant'
+doc:
+- audience: Node Operator
+  description: |-
+    The parachain informant was logging information for all parachains, not just ours. This PR fixes that by filtering the events by parachain ID.
+crates:
+- name: cumulus-client-service
+  bump: patch