mirror of
https://github.com/windmill-labs/windmill.git
synced 2026-09-10 08:07:03 +00:00
Ruben Fiszel
c0b87cc7d7
* supercharge * supercharge * progress * progress * display config * display config * display config * display config * fix extensions * fix build * disable nsjail = false for test
93 lines
2.9 KiB
Rust
93 lines
2.9 KiB
Rust
/*
|
|
* Author: Ruben Fiszel
|
|
* Copyright: Windmill Labs, Inc 2022
|
|
* This file and its contents are licensed under the AGPLv3 License.
|
|
* Please see the included NOTICE for copyright information and
|
|
* LICENSE-AGPL for a copy of the license.
|
|
*/
|
|
|
|
// use std::{net::SocketAddr, time::Duration};
|
|
|
|
// use anyhow::Context;
|
|
// use sqlx::{postgres::PgPoolOptions, Pool, Postgres};
|
|
// use windmill_common::{
|
|
// error::{self, Error},
|
|
// utils::rd_string,
|
|
// };
|
|
|
|
// #[tokio::main]
|
|
// async fn main() -> anyhow::Result<()> {
|
|
// // dotenv().ok();
|
|
|
|
// windmill_common::tracing_init::initialize_tracing();
|
|
|
|
// let db = async {
|
|
// let database_url = std::env::var("DATABASE_URL")
|
|
// .map_err(|_| Error::BadConfig("DATABASE_URL env var is missing".to_string()))?;
|
|
|
|
// let max_connections = match std::env::var("DATABASE_CONNECTIONS") {
|
|
// Ok(n) => n.parse::<u32>().context("invalid DATABASE_CONNECTIONS")?,
|
|
// Err(_) => 10,
|
|
// };
|
|
|
|
// Ok::<Pool<Postgres>, error::Error>(
|
|
// PgPoolOptions::new()
|
|
// .max_connections(max_connections)
|
|
// .max_lifetime(Duration::from_secs(30 * 60)) // 30 mins
|
|
// .connect(&database_url)
|
|
// .await
|
|
// .map_err(|err| Error::ConnectingToDatabase(err.to_string()))?,
|
|
// )
|
|
// }
|
|
// .await?;
|
|
|
|
// let metrics_addr: Option<SocketAddr> = std::env::var("METRICS_ADDR")
|
|
// .ok()
|
|
// .map(|s| {
|
|
// s.parse::<bool>()
|
|
// .map(|b| b.then(|| SocketAddr::from(([0, 0, 0, 0], 8001))))
|
|
// .or_else(|_| s.parse::<SocketAddr>().map(Some))
|
|
// })
|
|
// .transpose()?
|
|
// .flatten();
|
|
|
|
// let (tx, rx) = tokio::sync::broadcast::channel::<()>(3);
|
|
// let shutdown_signal = windmill_common::shutdown_signal(tx);
|
|
|
|
// let workers_f = async {
|
|
// let instance_name = rd_string(5);
|
|
|
|
// let ip = windmill_common::external_ip::get_ip()
|
|
// .await
|
|
// .unwrap_or_else(|e| {
|
|
// tracing::warn!(error = e.to_string(), "failed to get external IP");
|
|
// "unretrievable IP".to_string()
|
|
// });
|
|
// let worker_name = format!("dt-worker-{}-{}", &instance_name, rd_string(5));
|
|
// windmill_worker::run_worker(
|
|
// &db.clone(),
|
|
// &instance_name,
|
|
// worker_name,
|
|
// 1,
|
|
// 1,
|
|
// &ip,
|
|
// rx.resubscribe(),
|
|
// )
|
|
// .await;
|
|
// Ok(()) as anyhow::Result<()>
|
|
// };
|
|
|
|
// let metrics_f = async {
|
|
// match metrics_addr {
|
|
// Some(addr) => windmill_common::serve_metrics(addr, rx.resubscribe())
|
|
// .await
|
|
// .map_err(anyhow::Error::from),
|
|
// None => Ok(()),
|
|
// }
|
|
// };
|
|
|
|
// futures::try_join!(shutdown_signal, workers_f, metrics_f)?;
|
|
|
|
// Ok(())
|
|
// }
|