diff --git a/src/data.rs b/src/data.rs
index 1fdef9d..dd1d470 100644
--- a/src/data.rs
+++ b/src/data.rs
@@ -159,11 +159,6 @@ pub(crate) fn shell() -> String {
     return "/bin/sh".to_string();
 }
 
-/// Default id (`-1`)
-pub(crate) fn id() -> String {
-    return "-1".to_string();
-}
-
 /// Default revision (`1`)
 pub(crate) fn revision() -> String {
     return "1".to_string();
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,
         };
     }