{"header":{"message":"Debugging jobs synchronisation between builder and main","description":null,"timestamp":"2026-06-08T07:51:41.724384426Z","authors":[{}]},"hash":"OA64RZOMOMELKGZE4MKMBJH6E6WE7BMP7OZHWQCZENSUZZ2ISXFQC","authors":[{"login":"pmeunier","key":"8ES6e1QmLjuQn1DzS2DQRKebzCKPHpdf4E9hfwMqQoe7"}],"deps":{"hashes":[["OA64RZOMOMELKGZE4MKMBJH6E6WE7BMP7OZHWQCZENSUZZ2ISXFQC","Debugging jobs synchronisation between builder and main"],["AA",null],["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","Initial patch"],["IFYNLE5HO7JIZ5LJYNQ7ZQGK7C7RWPT54DFMCDHPT4CEGCZN7ACQC","Cargo.nix"],["YJLEG4WRYKKQJMMDRKIRG4T4L7ZZ7N777EKIRSHHWHNZYWZJ7G5AC","Basic CI infra (no runner yet)"],["PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC","update + CI"],["IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC","Avoid saving the result"],["X7GJK2QD5LRK3KDE2YMCNDTASB3TAK6VAHSCY3SOZBHAYDQ5KJ7QC","Update"],["YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","Initial attempt at CI/CD"],["W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC","Removing locks when deploying"]],"deps":["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","IFYNLE5HO7JIZ5LJYNQ7ZQGK7C7RWPT54DFMCDHPT4CEGCZN7ACQC","YJLEG4WRYKKQJMMDRKIRG4T4L7ZZ7N777EKIRSHHWHNZYWZJ7G5AC","PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC","IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC"],"known":["X7GJK2QD5LRK3KDE2YMCNDTASB3TAK6VAHSCY3SOZBHAYDQ5KJ7QC","YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC"]},"hunks":[{"Replacement":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":3,"ins":{"up_context":[{"change":5,"pos":4446}],"down_context":[{"change":5,"pos":4474}],"flag":"BLOCK","start":0,"end":50,"inode":{"change":4,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":4446},"to":{"change":5,"start":4446,"end":4474},"introduced_by":5}],"inode":{"change":4,"pos":65}},"ins_contents":[{"Add":" extract::{MatchedPath, Path, Request, State},"}],"del_contents":[{"Del":" extract::{Path, State},\n"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":24,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":4924}],"down_context":[{"change":4,"pos":276}],"flag":"BLOCK","start":51,"end":86,"inode":{"change":4,"pos":65}}},"contents":[{"Add":"use tower_http::trace::TraceLayer;"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":79,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":5745}],"down_context":[{"change":5,"pos":5745}],"flag":"BLOCK","start":87,"end":129,"inode":{"change":4,"pos":65}}},"contents":[{"Add":" .route(\"/kill/{job}\", post(kill))"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":83,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":5880}],"down_context":[{"change":5,"pos":5880}],"flag":"BLOCK","start":130,"end":661,"inode":{"change":4,"pos":65}}},"contents":[{"Add":" .layer("},{"Add":" TraceLayer::new_for_http()"},{"Add":" .make_span_with(|req: &Request| {"},{"Add":" let method = req.method();"},{"Add":" let uri = req.uri();"},{"Add":" let matched_path = req"},{"Add":" .extensions()"},{"Add":" .get::()"},{"Add":" .map(|matched_path| matched_path.as_str());"},{"Add":" tracing::debug_span!(\"request\", %method, %uri, matched_path)"},{"Add":" })"},{"Add":" .on_failure(()),"},{"Add":" )"}]}},{"Replacement":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":103,"ins":{"up_context":[{"change":5,"pos":6049}],"down_context":[{"change":6,"pos":230}],"flag":"BLOCK","start":662,"end":1056,"inode":{"change":4,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":6049},"to":{"change":5,"start":6049,"end":6084},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":6084},"to":{"change":6,"start":80,"end":230},"introduced_by":6}],"inode":{"change":4,"pos":65}},"ins_contents":[{"Add":") -> Result>, Error> {"},{"Add":" debug!(\"status\");"},{"Add":" let mut jobs = config.jobs.lock().unwrap();"},{"Add":" let mut closed = false;"},{"Add":" if let Some((kill, status)) = jobs.get_mut(&job) {"},{"Add":" let s = if let Some(s) = &*status.borrow_and_update() {"},{"Add":" Some(s.clone())"},{"Add":" } else {"},{"Add":" None"},{"Add":" };"},{"Add":" if kill.is_closed() {"},{"Add":" jobs.remove(&job);"}],"del_contents":[{"Del":") -> Result, Error> {\n"},{"Del":" if let Some((_, job)) = config.jobs.lock().unwrap().get(&job) {\n if let Some(s) = &*job.borrow() {\n return Ok(Json(s.clone()));\n"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":116,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":240}],"down_context":[{"change":6,"pos":240}],"flag":"BLOCK","start":1057,"end":1119,"inode":{"change":4,"pos":65}}},"contents":[{"Add":" debug!(\"status {:?}\", s);"},{"Add":" return Ok(Json(s));"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":119,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":246}],"down_context":[{"change":6,"pos":246}],"flag":"BLOCK","start":1120,"end":1152,"inode":{"change":4,"pos":65}}},"contents":[{"Add":" debug!(\"status not found\");"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":210,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":7476},"to":{"change":5,"start":8789,"end":8914},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":8914},"to":{"change":4,"start":8399,"end":8400},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":8399},"to":{"change":4,"start":8399,"end":8400},"introduced_by":4}],"inode":{"change":4,"pos":65}}},"contents":[{"Del":"// #[derive(Debug, Clone)]\n// struct RepoPath {\n// path: PathBuf,\n// remove_dir: bool,\n// remove_dot: bool,\n// }\n"},{"Del":"\n"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":215,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":9055}],"down_context":[{"change":5,"pos":9055}],"flag":"BLOCK","start":1153,"end":1455,"inode":{"change":4,"pos":65}}},"contents":[{"Add":" let (status_tx, status_rx) = tokio::sync::watch::channel(None);"},{"Add":" let (kill_tx, kill_rx) = tokio::sync::oneshot::channel();"},{"Add":" if let Some((k, _)) = config"},{"Add":" .jobs"},{"Add":" .lock()"},{"Add":" .unwrap()"},{"Add":" .insert(t.id, (kill_tx, status_rx))"},{"Add":" {"},{"Add":" k.send(()).unwrap_or(());"},{"Add":" }"},{"Add":""}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":274,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":10730},"to":{"change":5,"start":10694,"end":11035},"introduced_by":5}],"inode":{"change":4,"pos":65}}},"contents":[{"Del":" let (status_tx, status_rx) = tokio::sync::watch::channel(None);\n let (kill_tx, kill_rx) = tokio::sync::oneshot::channel();\n if let Some((k, _)) = config\n .jobs\n .lock()\n .unwrap()\n .insert(t.id, (kill_tx, status_rx))\n {\n k.send(()).unwrap_or(());\n }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":290,"ins":{"up_context":[{"change":6,"pos":368}],"down_context":[{"change":6,"pos":419}],"flag":"BLOCK","start":1456,"end":1512,"inode":{"change":4,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":368},"to":{"change":6,"start":368,"end":419},"introduced_by":6}],"inode":{"change":4,"pos":65}},"ins_contents":[{"Add":" status_tx.send(Some(status)).unwrap_or(());"}],"del_contents":[{"Del":" status_tx.send(Some(status)).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":297,"ins":{"up_context":[{"change":6,"pos":600}],"down_context":[{"change":6,"pos":651}],"flag":"BLOCK","start":1513,"end":1569,"inode":{"change":4,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":600},"to":{"change":6,"start":600,"end":651},"introduced_by":6}],"inode":{"change":4,"pos":65}},"ins_contents":[{"Add":" status_tx.send(Some(status)).unwrap_or(());"}],"del_contents":[{"Del":" status_tx.send(Some(status)).unwrap();\n"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":301,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":11693}],"down_context":[{"change":5,"pos":11693}],"flag":"BLOCK","start":1570,"end":1928,"inode":{"change":4,"pos":65}}},"contents":[{"Add":" Ok(StatusCode::OK)"},{"Add":"}"},{"Add":""},{"Add":"#[axum::debug_handler]"},{"Add":"pub async fn kill("},{"Add":" State(config): State,"},{"Add":" Path(job): Path,"},{"Add":") -> Result {"},{"Add":" if let Some((kill, job)) = config.jobs.lock().unwrap().get_mut(&job) {"},{"Add":" let k = std::mem::replace(kill, tokio::sync::oneshot::channel().0);"},{"Add":" k.send(()).unwrap_or(())"},{"Add":" }"}]}},{"Edit":{"inode":{"change":4,"pos":65},"path":"ci/src/main.rs","line":323,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":12030}],"down_context":[{"change":5,"pos":12030}],"flag":"BLOCK","start":1929,"end":1950,"inode":{"change":4,"pos":65}}},"contents":[{"Add":" debug!(\"build\");"}]}},{"Edit":{"inode":{"change":4,"pos":15386},"path":"ci/Cargo.toml","line":41,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":18952}],"down_context":[],"flag":"BLOCK","start":1951,"end":1979,"inode":{"change":4,"pos":15386}}},"contents":[{"Add":"tower-http.workspace = true"}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":423,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":881}],"down_context":[{"change":6,"pos":881}],"flag":"BLOCK","start":1980,"end":2031,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":" debug!(\"Status: {:?} -> {:?}\", job, code);"}]}},{"Replacement":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":425,"ins":{"up_context":[{"change":6,"pos":942}],"down_context":[{"change":6,"pos":943}],"flag":"BLOCK","start":2032,"end":2589,"inode":{"change":2,"pos":431834}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":6,"pos":942},"to":{"change":5,"start":44781,"end":45235},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":44781},"to":{"change":5,"start":44781,"end":45235},"introduced_by":5}],"inode":{"change":2,"pos":431834}},"ins_contents":[{"Add":" let status: Option = status.json().await.unwrap();"},{"Add":" if let Some(ref status) = status {"},{"Add":" debug!(\"STATUS {:?}\", status);"},{"Add":" use crate::db::jobs::dsl as jobs;"},{"Add":" diesel::update(jobs::jobs.find(job))"},{"Add":" .set(("},{"Add":" jobs::status.eq(status.code),"},{"Add":" jobs::ended.eq(status.finished),"},{"Add":" ))"},{"Add":" .execute(db)"},{"Add":" .await"},{"Add":" .unwrap();"},{"Add":" }"},{"Add":" status"}],"del_contents":[{"Del":" let status: ci::Status = status.json().await.unwrap();\n debug!(\"STATUS {:?}\", status);\n use crate::db::jobs::dsl as jobs;\n diesel::update(jobs::jobs.find(job))\n .set((\n jobs::status.eq(status.code),\n jobs::ended.eq(status.finished),\n ))\n .execute(db)\n .await\n .unwrap();\n Some(status)\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32096},"path":"api/src/jobs.rs","line":290,"ins":{"up_context":[{"change":5,"pos":54313}],"down_context":[{"change":5,"pos":54363}],"flag":"BLOCK","start":2590,"end":2647,"inode":{"change":7,"pos":32096}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":54313},"to":{"change":5,"start":54313,"end":54363},"introduced_by":5}],"inode":{"change":7,"pos":32096}},"ins_contents":[{"Add":" .await;"},{"Add":" debug!(\"{:?}\", res);"}],"del_contents":[{"Del":" .await\n .unwrap();\n"}]}},{"Replacement":{"inode":{"change":2,"pos":602339},"path":"api/Cargo.toml","line":80,"ins":{"up_context":[{"change":5,"pos":70335}],"down_context":[{"change":2,"pos":604437}],"flag":"BLOCK","start":2648,"end":2676,"inode":{"change":2,"pos":602339}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":70335},"to":{"change":5,"start":70335,"end":70490},"introduced_by":5}],"inode":{"change":2,"pos":602339}},"ins_contents":[{"Add":"tower-http.workspace = true"}],"del_contents":[{"Del":"tower-http = { version = \"0.6.11\", features = [ \"trace\", \"cors\", \"compression-br\", \"compression-gzip\", \"compression-zstd\", \"compression-deflate\", \"fs\" ] }\n"}]}},{"Replacement":{"inode":{"change":2,"pos":604664},"path":"Cargo.toml","line":40,"ins":{"up_context":[{"change":5,"pos":72012}],"down_context":[],"flag":"BLOCK","start":2677,"end":2853,"inode":{"change":2,"pos":604664}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":72012},"to":{"change":5,"start":72012,"end":72033},"introduced_by":5}],"inode":{"change":2,"pos":604664}},"ins_contents":[{"Add":"axum-extra = \"0.12.6\""},{"Add":"tower-http = { version = \"0.6.11\", features = [ \"trace\", \"cors\", \"compression-br\", \"compression-gzip\", \"compression-zstd\", \"compression-deflate\", \"fs\" ] }"}],"del_contents":[{"Del":"axum-extra = \"0.12.6\""}]}},{"Edit":{"inode":{"change":3,"pos":34},"path":"Cargo.nix","line":3111,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":85263}],"down_context":[{"change":3,"pos":85263}],"flag":"BLOCK","start":2854,"end":3074,"inode":{"change":3,"pos":34}}},"contents":[{"Add":" name = \"tower-http\";"},{"Add":" packageId = \"tower-http\";"},{"Add":" features = [ \"trace\" \"cors\" \"compression-br\" \"compression-gzip\" \"compression-zstd\" \"compression-deflate\" \"fs\" ];"},{"Add":" }"},{"Add":" {"}]}},{"Edit":{"inode":{"change":2,"pos":604770},"path":"Cargo.lock","line":947,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":77325}],"down_context":[{"change":2,"pos":627285}],"flag":"BLOCK","start":3075,"end":3090,"inode":{"change":2,"pos":604770}}},"contents":[{"Add":" \"tower-http\","}]}}],"owner":"pijul","repo":"nest","token":"r5zX+l6IhIWqv5rMTcIYsW/x3f3qVvKXYXbkMlT4kbE=","login":null}

…

Dependencies

Change contents