Skip to content

Commit a8cbcc6

Browse files
committed
chore: cleanup
1 parent bfdc0f7 commit a8cbcc6

File tree

4 files changed

+1
-19
lines changed

4 files changed

+1
-19
lines changed

server/src/handlers/http/modal/ingest_server.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,6 @@ impl ParseableServer for IngestServer {
104104
self.initialize().await
105105
}
106106

107-
#[allow(unused)]
108107
fn validate(&self) -> anyhow::Result<()> {
109108
if CONFIG.get_storage_mode_string() == "Local drive" {
110109
return Err(anyhow::Error::msg(
@@ -229,7 +228,7 @@ impl IngestServer {
229228
DEFAULT_VERSION.to_string(),
230229
store.get_bucket_name(),
231230
&CONFIG.parseable.username,
232-
&CONFIG.parseable.password, // is this secure?
231+
&CONFIG.parseable.password,
233232
);
234233

235234
let resource = serde_json::to_string(&resource)

server/src/handlers/http/modal/query_server.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,6 @@ impl ParseableServer for QueryServer {
112112
self.initialize().await
113113
}
114114

115-
#[allow(unused)]
116115
fn validate(&self) -> anyhow::Result<()> {
117116
if CONFIG.get_storage_mode_string() == "Local drive" {
118117
return Err(anyhow::anyhow!(

server/src/main.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -67,11 +67,7 @@ async fn main() -> anyhow::Result<()> {
6767
Mode::All => Arc::new(Server),
6868
};
6969

70-
// add logic for graceful shutdown if
7170
// MODE == Query / Ingest and storage = local-store
72-
// option.rs ln: 161
73-
// CONFIG.run_time_mode_validation()?;
74-
7571
server.init().await?;
7672

7773
Ok(())

server/src/option.rs

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -157,18 +157,6 @@ impl Config {
157157
}
158158
"S3 bucket"
159159
}
160-
161-
#[allow(dead_code)]
162-
pub fn run_time_mode_validation(&self) -> anyhow::Result<()> {
163-
let check = (self.parseable.mode == Mode::Ingest || self.parseable.mode == Mode::Query)
164-
&& self.storage_name == "drive";
165-
166-
if check {
167-
anyhow::bail!(format!("Cannot start the server in {} mode with local storage, please use S3 bucket for storage", self.parseable.mode.to_str()))
168-
}
169-
170-
Ok(())
171-
}
172160
}
173161

174162
fn create_parseable_cli_command() -> Command {

0 commit comments

Comments
 (0)