Chore/increase sled init timeout (#165)

* chore: increase sled init timeout to 6000s * chore: increase default timeout to 6000s
txpipe · Jun 3, 2024 · a593efd · a593efd
1 parent f6c09c6
commit a593efd
Show file tree

Hide file tree

Showing 7 changed files with 9 additions and 9 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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"),