From 2cd2ce7f7d42caaf10c325cecbd0987bb62fec0b Mon Sep 17 00:00:00 2001
From: Stuart Axelbrooke <stuart@axelbrooke.com>
Date: Thu, 16 Oct 2025 19:36:04 -0700
Subject: [PATCH] impl log line parsing

---
 databuild/data_deps.rs    | 3 ++-
 databuild/databuild.proto | 1 +
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/databuild/data_deps.rs b/databuild/data_deps.rs
index 03081aa..24cc638 100644
--- a/databuild/data_deps.rs
+++ b/databuild/data_deps.rs
@@ -2,6 +2,7 @@ use crate::JobRunMissingDeps;
 
 pub struct LogLine(String);
 
+// TODO - how do we version this?
 const DATABUILD_JSON: &str = "DATABUILD_MISSING_DEPS_JSON:";
 
 impl From<LogLine> for Option<JobRunMissingDeps> {
@@ -25,7 +26,7 @@ mod tests {
     #[test]
     fn test_parse_missing_deps_with_1_to_1_and_1_to_n() {
         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();
diff --git a/databuild/databuild.proto b/databuild/databuild.proto
index 26b9d36..8ef4c9b 100644
--- a/databuild/databuild.proto
+++ b/databuild/databuild.proto
@@ -87,6 +87,7 @@ message JobRunMissingDepsEventV1 {
   repeated MissingDeps missing_deps = 2;
 }
 message JobRunMissingDeps {
+  string version = 1;
   repeated MissingDeps missing_deps = 2;
 }
 message MissingDeps {