diff --git a/server/data_model/src/lib.rs b/server/data_model/src/lib.rs index c46cefc17..49ecdfa4a 100644 --- a/server/data_model/src/lib.rs +++ b/server/data_model/src/lib.rs @@ -1012,12 +1012,6 @@ impl StateChange { } else { key.push_str("global|"); } - if let Some(cg) = &self.compute_graph { - key.push_str(&format!("{}|", &cg)); - } - if let Some(inv) = &self.invocation { - key.push_str(&format!("{}|", &inv)); - } key.push_str(format!("{}", self.id).as_str()); key.as_bytes().to_vec() } diff --git a/server/state_store/src/state_machine.rs b/server/state_store/src/state_machine.rs index 596620e5e..e1cfbcecd 100644 --- a/server/state_store/src/state_machine.rs +++ b/server/state_store/src/state_machine.rs @@ -424,13 +424,6 @@ pub(crate) fn delete_invocation( // Delete Task Outputs // FIXME: This requires putting the invocation id in the task output key - // Delete State Changes for the invocation - delete_cf_prefix( - txn, - IndexifyObjectsColumns::UnprocessedStateChanges.cf_db(&db), - format!("ns_{}", prefix).as_bytes(), - )?; - // Delete Graph Invocation Context delete_cf_prefix( txn,