removido DB URL de workers
This commit is contained in:
+8
-3
@@ -30,7 +30,6 @@ async fn main() -> Result<()> {
|
|||||||
Mode::Worker => config,
|
Mode::Worker => config,
|
||||||
};
|
};
|
||||||
|
|
||||||
let database = Arc::new(Database::open(&config.database_url).await?);
|
|
||||||
let ui = Arc::new(TerminalUi::new(stdout_is_terminal()));
|
let ui = Arc::new(TerminalUi::new(stdout_is_terminal()));
|
||||||
let interrupted = Arc::new(AtomicBool::new(false));
|
let interrupted = Arc::new(AtomicBool::new(false));
|
||||||
|
|
||||||
@@ -43,8 +42,14 @@ async fn main() -> Result<()> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
let result = match config.mode {
|
let result = match config.mode {
|
||||||
Mode::Local => scan::run_local_scan(config, database, ui, interrupted).await,
|
Mode::Local => {
|
||||||
Mode::Coordinator => coordinator::run_coordinator(config, database, ui, interrupted).await,
|
let database = Arc::new(Database::open(&config.database_url).await?);
|
||||||
|
scan::run_local_scan(config, database, ui, interrupted).await
|
||||||
|
}
|
||||||
|
Mode::Coordinator => {
|
||||||
|
let database = Arc::new(Database::open(&config.database_url).await?);
|
||||||
|
coordinator::run_coordinator(config, database, ui, interrupted).await
|
||||||
|
}
|
||||||
Mode::Worker => worker::run_worker(config, ui).await,
|
Mode::Worker => worker::run_worker(config, ui).await,
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user