nit style

This commit is contained in:
Ruben Fiszel
2025-11-21 07:43:23 +00:00
parent 6f400fc7bb
commit 53ac97333d
2 changed files with 8 additions and 8 deletions
+1 -1
View File
@@ -1 +1 @@
7f27da56373dde0c37081f38227abc629436819e
40f77067886158bc816637004673ea5cf03a51f8
+7 -7
View File
@@ -211,7 +211,6 @@ lazy_static::lazy_static! {
}
pub fn main() -> anyhow::Result<()> {
// On Windows with enterprise feature, check if running as a service
#[cfg(all(windows, feature = "enterprise", feature = "private"))]
{
@@ -318,10 +317,6 @@ async fn cache_hub_scripts(file_path: Option<String>) -> anyhow::Result<()> {
}
async fn windmill_main() -> anyhow::Result<()> {
// windmill_common::db_iam::main().await?;
// return Ok(());
let (killpill_tx, mut killpill_rx) = KillpillSender::new(2);
let mut monitor_killpill_rx = killpill_tx.subscribe();
let (killpill_phase2_tx, _killpill_phase2_rx) = tokio::sync::broadcast::channel::<()>(2);
@@ -516,9 +511,14 @@ async fn windmill_main() -> anyhow::Result<()> {
conn
} else {
// This time we use a pool of connections
let db = windmill_common::connect_db(server_mode, indexer_mode, worker_mode,
let db = windmill_common::connect_db(
server_mode,
indexer_mode,
worker_mode,
#[cfg(feature = "private")]
killpill_rx.resubscribe()).await?;
killpill_rx.resubscribe(),
)
.await?;
// NOTE: Variable/resource cache initialization moved to API server in windmill-api