{"header":{"message":"CI: keeping track of status","description":null,"timestamp":"2026-06-08T09:57:16.504390843Z","authors":[{}]},"hash":"D4OFR55J32745WILDBAYROEZNRTIFG7VGQTOYSXO4CAB7K55RG5QC","authors":[{"login":"pmeunier","key":"8ES6e1QmLjuQn1DzS2DQRKebzCKPHpdf4E9hfwMqQoe7"}],"deps":{"hashes":[["D4OFR55J32745WILDBAYROEZNRTIFG7VGQTOYSXO4CAB7K55RG5QC","CI: keeping track of status"],["AA",null],["YJLEG4WRYKKQJMMDRKIRG4T4L7ZZ7N777EKIRSHHWHNZYWZJ7G5AC","Basic CI infra (no runner yet)"],["YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","Initial attempt at CI/CD"],["NRBML6UEXH5QCDVL7M4DNEU6XZ72SUKYUIPUTYHEFDOLM3Z6MKCAC","Updating ssh + debug"],["43PI2ASDQFPSI4TKEELSNCYQVKSVHBZCQFP7ZQ6RIFVBQAKHLKUQC","split stderr/stdout into smaller chunks in websocket"],["PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC","update + CI"],["IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC","Avoid saving the result"],["OA64RZOMOMELKGZE4MKMBJH6E6WE7BMP7OZHWQCZENSUZZ2ISXFQC","Debugging jobs synchronisation between builder and main"],["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","Initial patch"],["BTSWJ4D6AO4X5USFLQ67PORTMJNNOXKCUYPWYMB2YCQLO4XCQ3IQC","Correctly updating remote_stdout/remote_stderr"],["W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC","Removing locks when deploying"],["4DSEIE3VK6W6666GVSGOXQCSIMQDQQEFFFZW3C7FXZUYI2U6LTIQC","Make the jobs feature optional"],["4LI4UD4D7U23ZAIOKGDK637QQDM3A23OTXE6VGRRPD5TPHQZJOBQC","fixing a websocket issue on the jobs page"]],"deps":["YJLEG4WRYKKQJMMDRKIRG4T4L7ZZ7N777EKIRSHHWHNZYWZJ7G5AC","YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","NRBML6UEXH5QCDVL7M4DNEU6XZ72SUKYUIPUTYHEFDOLM3Z6MKCAC","43PI2ASDQFPSI4TKEELSNCYQVKSVHBZCQFP7ZQ6RIFVBQAKHLKUQC","PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC","IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC","OA64RZOMOMELKGZE4MKMBJH6E6WE7BMP7OZHWQCZENSUZZ2ISXFQC"],"known":["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","BTSWJ4D6AO4X5USFLQ67PORTMJNNOXKCUYPWYMB2YCQLO4XCQ3IQC","W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC","4DSEIE3VK6W6666GVSGOXQCSIMQDQQEFFFZW3C7FXZUYI2U6LTIQC","4LI4UD4D7U23ZAIOKGDK637QQDM3A23OTXE6VGRRPD5TPHQZJOBQC"]},"hunks":[{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":216,"ins":{"up_context":[{"change":8,"pos":1221}],"down_context":[{"change":8,"pos":1283}],"flag":"BLOCK","start":0,"end":66,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":1221},"to":{"change":8,"start":1221,"end":1283},"introduced_by":8}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" let (kill_tx, mut kill_rx) = tokio::sync::oneshot::channel();"}],"del_contents":[{"Del":" let (kill_tx, kill_rx) = tokio::sync::oneshot::channel();\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":279,"ins":{"up_context":[{"change":6,"pos":11148}],"down_context":[{"change":6,"pos":11192}],"flag":"BLOCK","start":67,"end":93,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":11148},"to":{"change":6,"start":11148,"end":11169},"introduced_by":6}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" &mut kill_rx,"}],"del_contents":[{"Del":" kill_rx,\n"}]}},{"Edit":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":282,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":11218},"to":{"change":6,"start":11218,"end":11269},"introduced_by":6}],"inode":{"change":2,"pos":65}}},"contents":[{"Del":" config.jobs.lock().unwrap().remove(&t.id);\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":320,"ins":{"up_context":[{"change":6,"pos":11855}],"down_context":[{"change":6,"pos":11968}],"flag":"BLOCK","start":94,"end":148,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":11855},"to":{"change":6,"start":11855,"end":11908},"introduced_by":6}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" kill_rx: &mut tokio::sync::oneshot::Receiver<()>,"}],"del_contents":[{"Del":" mut kill_rx: tokio::sync::oneshot::Receiver<()>,\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":356,"ins":{"up_context":[{"change":6,"pos":12957}],"down_context":[{"change":2,"pos":14104}],"flag":"BLOCK","start":149,"end":207,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":12957},"to":{"change":7,"start":662,"end":725},"introduced_by":7}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" let code = dump_cmd(cmd, &mut files, kill_rx).await?;"}],"del_contents":[{"Del":" let code = dump_cmd(cmd, &mut files, &mut kill_rx).await?;\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":388,"ins":{"up_context":[{"change":6,"pos":14053}],"down_context":[{"change":6,"pos":14173}],"flag":"BLOCK","start":208,"end":272,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":14053},"to":{"change":7,"start":726,"end":795},"introduced_by":7}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" Ok((dump_cmd(cmd, &mut files, kill_rx).await?, result))"}],"del_contents":[{"Del":" Ok((dump_cmd(cmd, &mut files, &mut kill_rx).await?, result))\n"}]}},{"Replacement":{"inode":{"change":9,"pos":431834},"path":"api/src/replication.rs","line":207,"ins":{"up_context":[{"change":6,"pos":41754}],"down_context":[{"change":6,"pos":41843}],"flag":"BLOCK","start":273,"end":423,"inode":{"change":9,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":41754},"to":{"change":6,"start":41754,"end":41843},"introduced_by":6}],"inode":{"change":9,"pos":431834}},"ins_contents":[{"Add":" sync_job(s.jobs.clone(), &mut db, s.client, &s.ci, n, id)"},{"Add":" .await;"}],"del_contents":[{"Del":" sync_job(&mut db, s.client, &s.ci, n, id).await;\n"}]}},{"Edit":{"inode":{"change":9,"pos":431834},"path":"api/src/replication.rs","line":392,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":43878}],"down_context":[{"change":6,"pos":43878}],"flag":"BLOCK","start":424,"end":455,"inode":{"change":9,"pos":431834}}},"contents":[{"Add":" jobs: crate::config::Jobs,"}]}},{"Edit":{"inode":{"change":9,"pos":431834},"path":"api/src/replication.rs","line":399,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":44034}],"down_context":[{"change":6,"pos":44034}],"flag":"BLOCK","start":456,"end":573,"inode":{"change":9,"pos":431834}}},"contents":[{"Add":" let (status_tx, status_rx) = tokio::sync::watch::channel(None);"},{"Add":" jobs.lock().unwrap().insert(job, status_rx);"}]}},{"Edit":{"inode":{"change":9,"pos":431834},"path":"api/src/replication.rs","line":431,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":2154}],"down_context":[{"change":8,"pos":2154}],"flag":"BLOCK","start":574,"end":644,"inode":{"change":9,"pos":431834}}},"contents":[{"Add":" status_tx.send(Some((status.finished, status.code)));"}]}},{"Replacement":{"inode":{"change":3,"pos":32096},"path":"api/src/jobs.rs","line":239,"ins":{"up_context":[{"change":6,"pos":52712}],"down_context":[{"change":6,"pos":52808}],"flag":"BLOCK","start":645,"end":982,"inode":{"change":3,"pos":32096}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":52712},"to":{"change":6,"start":52712,"end":52808},"introduced_by":6}],"inode":{"change":3,"pos":32096}},"ins_contents":[{"Add":" crate::replication::sync_job("},{"Add":" config.jobs.clone(),"},{"Add":" &mut db,"},{"Add":" client,"},{"Add":" &config.ci,"},{"Add":" n,"},{"Add":" id,"},{"Add":" )"},{"Add":" .await;"}],"del_contents":[{"Del":" crate::replication::sync_job(&mut db, client, &config.ci, n, id).await;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":32096},"path":"api/src/jobs.rs","line":409,"ins":{"up_context":[{"change":4,"pos":1619}],"down_context":[{"change":3,"pos":36696}],"flag":"BLOCK","start":983,"end":1073,"inode":{"change":3,"pos":32096}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":1619},"to":{"change":3,"start":36549,"end":36696},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":36549},"to":{"change":3,"start":36549,"end":36696},"introduced_by":3}],"inode":{"change":3,"pos":32096}},"ins_contents":[{"Add":" let Some(mut status) = config.jobs.lock().unwrap().get(&id).map(|w| w.clone()) else {"}],"del_contents":[{"Del":" let Some(mut status) = config\n .jobs\n .lock()\n .unwrap()\n .get(&id)\n .map(|(_, _, w)| w.clone())\n else {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":32096},"path":"api/src/jobs.rs","line":497,"ins":{"up_context":[{"change":5,"pos":381}],"down_context":[{"change":3,"pos":39324}],"flag":"BLOCK","start":1074,"end":1141,"inode":{"change":3,"pos":32096}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":381},"to":{"change":5,"start":381,"end":413},"introduced_by":5}],"inode":{"change":3,"pos":32096}},"ins_contents":[{"Add":") -> Result>, crate::Error> {"}],"del_contents":[{"Del":") -> Result<(), crate::Error> {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":32096},"path":"api/src/jobs.rs","line":520,"ins":{"up_context":[{"change":5,"pos":720}],"down_context":[{"change":5,"pos":747}],"flag":"BLOCK","start":1142,"end":1172,"inode":{"change":3,"pos":32096}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":720},"to":{"change":5,"start":720,"end":747},"introduced_by":5}],"inode":{"change":3,"pos":32096}},"ins_contents":[{"Add":" return Ok(ended);"}],"del_contents":[{"Del":" return Ok(());\n"}]}},{"Edit":{"inode":{"change":3,"pos":32096},"path":"api/src/jobs.rs","line":582,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":2635}],"down_context":[{"change":3,"pos":40950}],"flag":"BLOCK","start":1173,"end":1221,"inode":{"change":3,"pos":32096}}},"contents":[{"Add":" Ok(ended)"},{"Add":" } else {"},{"Add":" Ok(None)"}]}},{"Edit":{"inode":{"change":3,"pos":32096},"path":"api/src/jobs.rs","line":586,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":40956},"to":{"change":5,"start":2636,"end":2647},"introduced_by":5}],"inode":{"change":3,"pos":32096}}},"contents":[{"Del":" Ok(())\n"}]}},{"Replacement":{"inode":{"change":9,"pos":532759},"path":"api/src/config.rs","line":87,"ins":{"up_context":[{"change":3,"pos":43083}],"down_context":[{"change":3,"pos":43360}],"flag":"BLOCK","start":1222,"end":1318,"inode":{"change":9,"pos":532759}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":43083},"to":{"change":3,"start":43083,"end":43360},"introduced_by":3}],"inode":{"change":9,"pos":532759}},"ins_contents":[{"Add":" tokio::sync::watch::Receiver, Option)>>,"}],"del_contents":[{"Del":" (\n tokio::sync::oneshot::Sender<()>,\n tokio::sync::watch::Sender, Option)>>,\n tokio::sync::watch::Receiver, Option)>>,\n ),\n"}]}}],"owner":"pijul","repo":"nest","token":"u2pq0LOHK2oE/jzJg4U1xHdh10/gfsLdmIxHodjEP/8=","login":null}

…

Dependencies

Change contents