Skip to content

Commit a593efd

Browse files
authored
Chore/increase sled init timeout (#165)
* chore: increase sled init timeout to 6000s * chore: increase default timeout to 6000s
1 parent f6c09c6 commit a593efd

File tree

7 files changed

+9
-9
lines changed

7 files changed

+9
-9
lines changed

src/enrich/skip.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ impl Bootstrapper {
4242
pipeline.register_stage(spawn_stage(
4343
worker,
4444
gasket::runtime::Policy {
45-
tick_timeout: Some(Duration::from_secs(600)),
45+
tick_timeout: Some(Duration::from_secs(6000)),
4646
..Default::default()
4747
},
4848
Some("enrich-skip"),

src/reducers/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@ pub mod address_by_asset;
2020
#[cfg(feature = "unstable")]
2121
pub mod address_by_txo;
2222
#[cfg(feature = "unstable")]
23+
pub mod addresses_by_stake;
24+
#[cfg(feature = "unstable")]
2325
pub mod asset_holders_by_asset_id;
2426
#[cfg(feature = "unstable")]
2527
pub mod balance_by_address;
@@ -39,8 +41,6 @@ pub mod tx_count_by_native_token_policy_id;
3941
pub mod utxo_by_stake;
4042
#[cfg(feature = "unstable")]
4143
pub mod utxos_by_asset;
42-
#[cfg(feature = "unstable")]
43-
pub mod addresses_by_stake;
4444

4545
#[derive(Deserialize)]
4646
#[serde(tag = "type")]
@@ -155,7 +155,7 @@ impl Bootstrapper {
155155
pipeline.register_stage(spawn_stage(
156156
worker,
157157
gasket::runtime::Policy {
158-
tick_timeout: Some(Duration::from_secs(600)),
158+
tick_timeout: Some(Duration::from_secs(6000)),
159159
..Default::default()
160160
},
161161
Some("reducers"),

src/sources/n2c/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ impl Bootstrapper {
6060
self.output,
6161
),
6262
gasket::runtime::Policy {
63-
tick_timeout: Some(Duration::from_secs(600)),
63+
tick_timeout: Some(Duration::from_secs(6000)),
6464
bootstrap_retry: gasket::retries::Policy {
6565
max_retries: 20,
6666
backoff_factor: 2,

src/sources/n2n/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ impl Bootstrapper {
8282
self.output,
8383
),
8484
gasket::runtime::Policy {
85-
tick_timeout: Some(Duration::from_secs(600)),
85+
tick_timeout: Some(Duration::from_secs(6000)),
8686
bootstrap_retry: gasket::retries::Policy {
8787
max_retries: 20,
8888
backoff_factor: 2,

src/storage/elastic.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ impl Bootstrapper {
9090
pipeline.register_stage(spawn_stage(
9191
worker,
9292
gasket::runtime::Policy {
93-
tick_timeout: Some(Duration::from_secs(600)),
93+
tick_timeout: Some(Duration::from_secs(6000)),
9494
bootstrap_retry: gasket::retries::Policy {
9595
max_retries: 20,
9696
backoff_unit: Duration::from_secs(1),

src/storage/redis.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ impl Bootstrapper {
7676
pipeline.register_stage(spawn_stage(
7777
worker,
7878
gasket::runtime::Policy {
79-
tick_timeout: Some(Duration::from_secs(600)),
79+
tick_timeout: Some(Duration::from_secs(6000)),
8080
bootstrap_retry: gasket::retries::Policy {
8181
max_retries: 20,
8282
backoff_unit: Duration::from_secs(1),

src/storage/skip.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ impl Bootstrapper {
4949
pipeline.register_stage(spawn_stage(
5050
worker,
5151
gasket::runtime::Policy {
52-
tick_timeout: Some(Duration::from_secs(600)),
52+
tick_timeout: Some(Duration::from_secs(6000)),
5353
..Default::default()
5454
},
5555
Some("skip"),

0 commit comments

Comments
 (0)