From b4973f28b4a1e694cac72a5ee8f9a54bbb487d3b Mon Sep 17 00:00:00 2001 From: Paul Hauner Date: Tue, 11 Jul 2023 15:32:48 +1000 Subject: [PATCH] Review priorties --- beacon_node/http_api/src/lib.rs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/beacon_node/http_api/src/lib.rs b/beacon_node/http_api/src/lib.rs index 4cc9408d4b..901e936013 100644 --- a/beacon_node/http_api/src/lib.rs +++ b/beacon_node/http_api/src/lib.rs @@ -1348,7 +1348,7 @@ pub fn serve( chain: Arc>, network_tx: UnboundedSender>, log: Logger| { - task_spawner.spawn_async_with_rejection(Priority::P1, async move { + task_spawner.spawn_async_with_rejection(Priority::P0, async move { publish_blocks::publish_blinded_block( block, chain, @@ -1379,7 +1379,7 @@ pub fn serve( chain: Arc>, network_tx: UnboundedSender>, log: Logger| { - task_spawner.spawn_async(Priority::P1, async move { + task_spawner.spawn_async(Priority::P0, async move { match publish_blocks::publish_blinded_block( block, chain, @@ -2245,7 +2245,7 @@ pub fn serve( .and(chain_filter.clone()) .and_then( move |task_spawner: TaskSpawner, chain: Arc>| { - task_spawner.blocking_json_task(Priority::P1, move || { + task_spawner.blocking_json_task(Priority::P0, move || { let config_and_preset = ConfigAndPreset::from_chain_spec::(&chain.spec, spec_fork_name); Ok(api_types::GenericResponse::from(config_and_preset)) @@ -2881,7 +2881,7 @@ pub fn serve( query: api_types::ValidatorBlocksQuery, task_spawner: TaskSpawner, chain: Arc>| { - task_spawner.spawn_async_with_rejection(Priority::P1, async move { + task_spawner.spawn_async_with_rejection(Priority::P0, async move { let randao_reveal = query.randao_reveal.decompress().map_err(|e| { warp_utils::reject::custom_bad_request(format!( "randao reveal is not a valid BLS signature: {:?}", @@ -3554,7 +3554,7 @@ pub fn serve( .and(warp::path::end()) .and(task_spawner_filter.clone()) .and_then(|task_spawner: TaskSpawner| { - task_spawner.blocking_json_task(Priority::P1, move || { + task_spawner.blocking_json_task(Priority::P0, move || { eth2::lighthouse::Health::observe() .map(api_types::GenericResponse::from) .map_err(warp_utils::reject::custom_bad_request) @@ -3577,7 +3577,7 @@ pub fn serve( app_start: std::time::Instant, data_dir, network_globals| { - task_spawner.blocking_json_task(Priority::P1, move || { + task_spawner.blocking_json_task(Priority::P0, move || { let app_uptime = app_start.elapsed().as_secs(); Ok(api_types::GenericResponse::from(observe_system_health_bn( sysinfo, @@ -3651,7 +3651,7 @@ pub fn serve( .and_then( |task_spawner: TaskSpawner, network_globals: Arc>| { - task_spawner.blocking_json_task(Priority::P1, move || { + task_spawner.blocking_json_task(Priority::P0, move || { Ok(api_types::GenericResponse::from( network_globals.sync_state(), ))