Compare commits

..

2 commits

Author SHA1 Message Date
askiiart
19562d2db6
remove sql connection from State 2025-01-30 16:47:02 -06:00
askiiart
63412ea204
remove old remnant 2025-01-30 16:40:49 -06:00
2 changed files with 1 additions and 14 deletions

View file

@ -159,11 +159,6 @@ pub(crate) fn shell() -> String {
return "/bin/sh".to_string(); return "/bin/sh".to_string();
} }
/// Default id (`-1`)
pub(crate) fn id() -> String {
return "-1".to_string();
}
/// Default revision (`1`) /// Default revision (`1`)
pub(crate) fn revision() -> String { pub(crate) fn revision() -> String {
return "1".to_string(); return "1".to_string();

View file

@ -81,7 +81,7 @@ async fn run(config_path: String) {
let job_exit_status = run_job(&state.conf, job_id.clone(), job.clone()); let job_exit_status = run_job(&state.conf, job_id.clone(), job.clone());
sql::log_job( sql::log_job(
pg_connection.as_mut(), &mut pg_connection,
start_time, start_time,
start_time + job_exit_status.duration, start_time + job_exit_status.duration,
job_exit_status.exit_code, job_exit_status.exit_code,
@ -297,13 +297,6 @@ struct State {
dependency_map: HashMap<String, Vec<String>>, dependency_map: HashMap<String, Vec<String>>,
/// A hashmap mapping all job ids to their jobs /// A hashmap mapping all job ids to their jobs
jobs: HashMap<String, Job>, 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 { impl State {
@ -335,7 +328,6 @@ impl State {
conf: conf.clone(), conf: conf.clone(),
jobs: jobs.clone(), jobs: jobs.clone(),
dependency_map: State::dependency_map(jobs, conf), dependency_map: State::dependency_map(jobs, conf),
sql: logging::sql::start(5).await,
}; };
} }