From 19562d2db66b556fe16d1cb90c6b52005c556163 Mon Sep 17 00:00:00 2001
From: askiiart <dev@askiiart.net>
Date: Thu, 30 Jan 2025 16:47:02 -0600
Subject: [PATCH] remove sql connection from State
---
src/main.rs | 10 +---------
1 file changed, 1 insertion(+), 9 deletions(-)
diff --git a/src/main.rs b/src/main.rs
index 314ae09..9501547 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -81,7 +81,7 @@ async fn run(config_path: String) {
let job_exit_status = run_job(&state.conf, job_id.clone(), job.clone());
sql::log_job(
- pg_connection.as_mut(),
+ &mut pg_connection,
start_time,
start_time + job_exit_status.duration,
job_exit_status.exit_code,
@@ -297,13 +297,6 @@ struct State {
dependency_map: HashMap<String, Vec<String>>,
/// A hashmap mapping all job ids to their jobs
jobs: HashMap<String, Job>,
- /// The connection to the database
- ///
- /// Example (from sqlx README, modified)
- /// ```ignore
- /// sqlx::query("DELETE FROM table").execute(&mut state.conn).await?;
- /// ```
- sql: PgConnection,
}
impl State {
@@ -335,7 +328,6 @@ impl State {
conf: conf.clone(),
jobs: jobs.clone(),
dependency_map: State::dependency_map(jobs, conf),
- sql: logging::sql::start(5).await,
};
}