diff --git a/Cargo.lock b/Cargo.lock index 12b0d5f267..c3af9f79f4 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -2373,6 +2373,7 @@ name = "ioxd_compactor" version = "0.1.0" dependencies = [ "async-trait", + "backoff", "clap_blocks", "compactor", "data_types", diff --git a/ioxd_compactor/Cargo.toml b/ioxd_compactor/Cargo.toml index f1577a21ff..33cfe770ac 100644 --- a/ioxd_compactor/Cargo.toml +++ b/ioxd_compactor/Cargo.toml @@ -7,6 +7,7 @@ edition = "2021" [dependencies] # Workspace dependencies, in alphabetical order +backoff = { path = "../backoff" } clap_blocks = { path = "../clap_blocks" } compactor = { path = "../compactor" } data_types = { path = "../data_types" } diff --git a/ioxd_compactor/src/lib.rs b/ioxd_compactor/src/lib.rs index 3f30e3e1a3..90af1b73a3 100644 --- a/ioxd_compactor/src/lib.rs +++ b/ioxd_compactor/src/lib.rs @@ -176,16 +176,19 @@ pub async fn create_compactor_server_type( compactor_config.input_file_count_threshold, compactor_config.hot_multiple, ); - let compactor_handler = Arc::new(CompactorHandlerImpl::new( + + let compactor = compactor::compact::Compactor::new( sequencers, catalog, parquet_store, exec, time_provider, - Arc::clone(&metric_registry), + backoff::BackoffConfig::default(), compactor_config, - )); + Arc::clone(&metric_registry), + ); + let compactor_handler = Arc::new(CompactorHandlerImpl::new_with_compactor(compactor)); let compactor = CompactorServer::new(metric_registry, compactor_handler); Ok(Arc::new(CompactorServerType::new(compactor, common_state))) }