From 4578776f578ce04452cae85b8b201f014fc97525 Mon Sep 17 00:00:00 2001
From: askiiart <dev@askiiart.net>
Date: Thu, 30 Jan 2025 12:06:40 -0600
Subject: [PATCH] remove old todo and format
---
src/data.rs | 2 +-
src/main.rs | 15 +++++----------
2 files changed, 6 insertions(+), 11 deletions(-)
diff --git a/src/data.rs b/src/data.rs
index 47e7649..1fdef9d 100644
--- a/src/data.rs
+++ b/src/data.rs
@@ -111,7 +111,7 @@ pub(crate) struct JobExitStatus {
/// The name of the container this job ran in
pub(crate) container_name: String,
/// Uuid
- pub(crate) job_uuid: String
+ pub(crate) job_uuid: String,
}
// ==========================
diff --git a/src/main.rs b/src/main.rs
index 1919b5c..314ae09 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -72,16 +72,14 @@ async fn run(config_path: String) {
// TODO: Add logic to add repo update repos when relevant (see dependencies) here - or maybe do that logic earlier?
let failed_packages: Vec<String> = Vec::new();
-
-
+
let mut pg_connection = sql::start(5).await;
-
+
// runs the jobs (will need to be updated after sorting is added)
for (job_id, job) in state.jobs {
let start_time = SystemTime::now();
let job_exit_status = run_job(&state.conf, job_id.clone(), job.clone());
- // TODO: PUSH IT TO THE DB HERE
sql::log_job(
pg_connection.as_mut(),
start_time,
@@ -91,15 +89,12 @@ async fn run(config_path: String) {
job.revision,
job_exit_status.job_uuid,
job_exit_status.log_path,
- ).await;
+ )
+ .await;
}
}
-fn run_job(
- conf: &Config,
- job_id: String,
- job: Job,
-) -> JobExitStatus {
+fn run_job(conf: &Config, job_id: String, job: Job) -> JobExitStatus {
// limit threads to max_threads in the config
let mut threads = job.threads;
if job.threads > conf.max_threads {