stuart/databuild
1
1
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

impl log line parsing

Browse source
This commit is contained in:
Stuart Axelbrooke 2025-10-16 19:36:04 -07:00
parent 9559a410d3
commit 2cd2ce7f7d
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
databuild/data_deps.rs
View file

@ -2,6 +2,7 @@ use crate::JobRunMissingDeps;
pub struct LogLine(String); pub struct LogLine(String);
// TODO - how do we version this?
const DATABUILD_JSON: &str = "DATABUILD_MISSING_DEPS_JSON:"; const DATABUILD_JSON: &str = "DATABUILD_MISSING_DEPS_JSON:";
impl From<LogLine> for Option<JobRunMissingDeps> { impl From<LogLine> for Option<JobRunMissingDeps> {
@ -25,7 +26,7 @@ mod tests {
#[test] #[test]
fn test_parse_missing_deps_with_1_to_1_and_1_to_n() { fn test_parse_missing_deps_with_1_to_1_and_1_to_n() {
let log_line = LogLine( let log_line = LogLine(
r#"DATABUILD_MISSING_DEPS_JSON:{"missing_deps":[{"impacted":[{"ref":"output/p1"}],"missing":[{"ref":"input/p1"}]},{"impacted":[{"ref":"output/p2"},{"ref":"output/p3"}],"missing":[{"ref":"input/p2"}]}]}"#.to_string() r#"DATABUILD_MISSING_DEPS_JSON:{"version":"1","missing_deps":[{"impacted":[{"ref":"output/p1"}],"missing":[{"ref":"input/p1"}]},{"impacted":[{"ref":"output/p2"},{"ref":"output/p3"}],"missing":[{"ref":"input/p2"}]}]}"#.to_string()
); );
let result: Option<JobRunMissingDeps> = log_line.into(); let result: Option<JobRunMissingDeps> = log_line.into();

1
databuild/databuild.proto
View file

@ -87,6 +87,7 @@ message JobRunMissingDepsEventV1 {
repeated MissingDeps missing_deps = 2; repeated MissingDeps missing_deps = 2;
} }
message JobRunMissingDeps { message JobRunMissingDeps {
string version = 1;
repeated MissingDeps missing_deps = 2; repeated MissingDeps missing_deps = 2;
} }
message MissingDeps { message MissingDeps {