diff --git a/crates/sui-data-ingestion/src/main.rs b/crates/sui-data-ingestion/src/main.rs index 71e49acb6f154..91eb768489579 100644 --- a/crates/sui-data-ingestion/src/main.rs +++ b/crates/sui-data-ingestion/src/main.rs @@ -6,6 +6,7 @@ use prometheus::Registry; use serde::{Deserialize, Serialize}; use std::env; use std::path::PathBuf; +use std::time::Duration; use sui_data_ingestion::{ ArchivalConfig, ArchivalReducer, ArchivalWorker, BlobTaskConfig, BlobWorker, DynamoDBProgressStore, KVStoreTaskConfig, KVStoreWorker, @@ -154,7 +155,12 @@ async fn main() -> Result<()> { executor.register(worker_pool).await?; } Task::BigTableKV(kv_config) => { - let client = BigTableClient::new_remote(kv_config.instance_id, false, None).await?; + let client = BigTableClient::new_remote( + kv_config.instance_id, + false, + Some(Duration::from_secs(15)), + ) + .await?; let worker_pool = WorkerPool::new( KvWorker { client }, task_config.name,