diff --git a/src/runtime/consensus.rs b/src/runtime/consensus.rs
index ddb3e086df412d7b43532c04f2cd6d41d2e4b22b..af043c10367dba4b228e5d5eb460ee29180a62c2 100644
--- a/src/runtime/consensus.rs
+++ b/src/runtime/consensus.rs
@@ -121,13 +121,6 @@ impl Consensus {
         return !self.branch_annotations.is_empty();
     }
 
-    #[deprecated]
-    pub fn get_annotation(&self, branch_id: BranchId, channel_id: PortIdLocal) -> &ChannelAnnotation {
-        let branch = &self.branch_annotations[branch_id.index as usize];
-        let port = branch.channel_mapping.iter().find(|v| v.channel_id.index == channel_id.index).unwrap();
-        return port;
-    }
-
     /// Sets up the consensus algorithm for a new synchronous round. The
     /// provided ports should be the ports the component owns at the start of
     /// the sync round.
@@ -301,12 +294,12 @@ impl Consensus {
 
     /// Notifies the consensus algorithm about the chosen branch to commit to
     /// memory (may be the invalid "start" branch)
-    pub fn end_sync(&mut self, branch_id: BranchId, final_ports: &mut Vec<ComponentPortChange>) {
+    pub fn end_sync(&mut self, branch_id: BranchId, _final_ports: &mut Vec<ComponentPortChange>) {
         debug_assert!(self.is_in_sync());
 
         // TODO: Handle sending and receiving ports
         // Set final ports
-        let branch = &self.branch_annotations[branch_id.index as usize];
+        let _branch = &self.branch_annotations[branch_id.index as usize];
 
         // Clear out internal storage to defaults
         println!("DEBUG: ***** Incrementing sync round stuff");
@@ -352,7 +345,7 @@ impl Consensus {
         find_ports_in_value_group(content, &mut self.workspace_ports);
         if !self.workspace_ports.is_empty() {
             todo!("handle sending ports");
-            self.workspace_ports.clear();
+            // self.workspace_ports.clear();
         }
 
         // Construct data header
@@ -554,7 +547,7 @@ impl Consensus {
                 find_ports_in_value_group(&message.content, &mut self.workspace_ports);
                 if !self.workspace_ports.is_empty() {
                     todo!("handle received ports");
-                    self.workspace_ports.clear();
+                    // self.workspace_ports.clear();
                 }
 
                 return;