From a593efda16126775ce2365946ed4ff9f835f7441 Mon Sep 17 00:00:00 2001 From: Alejandro Avagnina Date: Mon, 3 Jun 2024 18:52:55 -0300 Subject: [PATCH] Chore/increase sled init timeout (#165) * chore: increase sled init timeout to 6000s * chore: increase default timeout to 6000s --- src/enrich/skip.rs | 2 +- src/reducers/mod.rs | 6 +++--- src/sources/n2c/mod.rs | 2 +- src/sources/n2n/mod.rs | 2 +- src/storage/elastic.rs | 2 +- src/storage/redis.rs | 2 +- src/storage/skip.rs | 2 +- 7 files changed, 9 insertions(+), 9 deletions(-) diff --git a/src/enrich/skip.rs b/src/enrich/skip.rs index e995a81e..ea4b1daf 100644 --- a/src/enrich/skip.rs +++ b/src/enrich/skip.rs @@ -42,7 +42,7 @@ impl Bootstrapper { pipeline.register_stage(spawn_stage( worker, gasket::runtime::Policy { - tick_timeout: Some(Duration::from_secs(600)), + tick_timeout: Some(Duration::from_secs(6000)), ..Default::default() }, Some("enrich-skip"), diff --git a/src/reducers/mod.rs b/src/reducers/mod.rs index a02626de..042332ca 100644 --- a/src/reducers/mod.rs +++ b/src/reducers/mod.rs @@ -20,6 +20,8 @@ pub mod address_by_asset; #[cfg(feature = "unstable")] pub mod address_by_txo; #[cfg(feature = "unstable")] +pub mod addresses_by_stake; +#[cfg(feature = "unstable")] pub mod asset_holders_by_asset_id; #[cfg(feature = "unstable")] pub mod balance_by_address; @@ -39,8 +41,6 @@ pub mod tx_count_by_native_token_policy_id; pub mod utxo_by_stake; #[cfg(feature = "unstable")] pub mod utxos_by_asset; -#[cfg(feature = "unstable")] -pub mod addresses_by_stake; #[derive(Deserialize)] #[serde(tag = "type")] @@ -155,7 +155,7 @@ impl Bootstrapper { pipeline.register_stage(spawn_stage( worker, gasket::runtime::Policy { - tick_timeout: Some(Duration::from_secs(600)), + tick_timeout: Some(Duration::from_secs(6000)), ..Default::default() }, Some("reducers"), diff --git a/src/sources/n2c/mod.rs b/src/sources/n2c/mod.rs index f0141637..99e8f85f 100644 --- a/src/sources/n2c/mod.rs +++ b/src/sources/n2c/mod.rs @@ -60,7 +60,7 @@ impl Bootstrapper { self.output, ), gasket::runtime::Policy { - tick_timeout: Some(Duration::from_secs(600)), + tick_timeout: Some(Duration::from_secs(6000)), bootstrap_retry: gasket::retries::Policy { max_retries: 20, backoff_factor: 2, diff --git a/src/sources/n2n/mod.rs b/src/sources/n2n/mod.rs index 54884e69..db40cd1a 100644 --- a/src/sources/n2n/mod.rs +++ b/src/sources/n2n/mod.rs @@ -82,7 +82,7 @@ impl Bootstrapper { self.output, ), gasket::runtime::Policy { - tick_timeout: Some(Duration::from_secs(600)), + tick_timeout: Some(Duration::from_secs(6000)), bootstrap_retry: gasket::retries::Policy { max_retries: 20, backoff_factor: 2, diff --git a/src/storage/elastic.rs b/src/storage/elastic.rs index da3366cd..ae30561a 100644 --- a/src/storage/elastic.rs +++ b/src/storage/elastic.rs @@ -90,7 +90,7 @@ impl Bootstrapper { pipeline.register_stage(spawn_stage( worker, gasket::runtime::Policy { - tick_timeout: Some(Duration::from_secs(600)), + tick_timeout: Some(Duration::from_secs(6000)), bootstrap_retry: gasket::retries::Policy { max_retries: 20, backoff_unit: Duration::from_secs(1), diff --git a/src/storage/redis.rs b/src/storage/redis.rs index 5d28c371..5f550dea 100644 --- a/src/storage/redis.rs +++ b/src/storage/redis.rs @@ -76,7 +76,7 @@ impl Bootstrapper { pipeline.register_stage(spawn_stage( worker, gasket::runtime::Policy { - tick_timeout: Some(Duration::from_secs(600)), + tick_timeout: Some(Duration::from_secs(6000)), bootstrap_retry: gasket::retries::Policy { max_retries: 20, backoff_unit: Duration::from_secs(1), diff --git a/src/storage/skip.rs b/src/storage/skip.rs index d0b186f7..c6e93a77 100644 --- a/src/storage/skip.rs +++ b/src/storage/skip.rs @@ -49,7 +49,7 @@ impl Bootstrapper { pipeline.register_stage(spawn_stage( worker, gasket::runtime::Policy { - tick_timeout: Some(Duration::from_secs(600)), + tick_timeout: Some(Duration::from_secs(6000)), ..Default::default() }, Some("skip"),