Skip to content

Commit

Permalink
Updated namespace key schema
Browse files Browse the repository at this point in the history
  • Loading branch information
diptanu committed Jan 14, 2025
1 parent fd7520c commit 322e59a
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 13 deletions.
6 changes: 0 additions & 6 deletions server/data_model/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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()
}
Expand Down
7 changes: 0 additions & 7 deletions server/state_store/src/state_machine.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit 322e59a

Please sign in to comment.