Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Companion to substrate #10196 - Add group name in task metrics #732

Merged
merged 7 commits into from
Nov 11, 2021
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion client/collator/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -390,7 +390,7 @@ mod tests {
.build()
.expect("Builds overseer");

spawner.spawn("overseer", overseer.run().then(|_| async { () }).boxed());
spawner.spawn("overseer", "", overseer.run().then(|_| async { () }).boxed());

let collator_start = start_collator(StartCollatorParams {
runtime_api: client.clone(),
Expand Down
1 change: 1 addition & 0 deletions client/network/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -522,6 +522,7 @@ impl<Block: BlockT> WaitToAnnounce<Block> {

self.spawner.spawn(
"cumulus-wait-to-announce",
"",
async move {
tracing::debug!(
target: "cumulus-network",
Expand Down
12 changes: 8 additions & 4 deletions client/service/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,9 @@ where
self.announce_block,
);

self.task_manager.spawn_essential_handle().spawn("cumulus-consensus", consensus);
self.task_manager
.spawn_essential_handle()
.spawn("cumulus-consensus", "", consensus);
}
}

Expand Down Expand Up @@ -281,9 +283,11 @@ where
self.para_id,
);

self.task_manager
.spawn_essential_handle()
.spawn("cumulus-pov-recovery", pov_recovery.run());
self.task_manager.spawn_essential_handle().spawn(
"cumulus-pov-recovery",
"",
pov_recovery.run(),
);

Ok(())
}
Expand Down
2 changes: 1 addition & 1 deletion parachain-template/node/src/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ where
let telemetry_worker_handle = telemetry.as_ref().map(|(worker, _)| worker.handle());

let telemetry = telemetry.map(|(worker, telemetry)| {
task_manager.spawn_handle().spawn("telemetry", worker.run());
task_manager.spawn_handle().spawn("telemetry", "", worker.run());
telemetry
});

Expand Down
2 changes: 1 addition & 1 deletion polkadot-parachains/src/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ where
let telemetry_worker_handle = telemetry.as_ref().map(|(worker, _)| worker.handle());

let telemetry = telemetry.map(|(worker, telemetry)| {
task_manager.spawn_handle().spawn("telemetry", worker.run());
task_manager.spawn_handle().spawn("telemetry", "", worker.run());
telemetry
});

Expand Down