diff --git a/src/runtime/connector.rs b/src/runtime/connector.rs index 2aabac130545b88c7fb292d41e42d6a7a12b7493..61c5cf3d33ceefe32088c782e08608ecce5e0d81 100644 --- a/src/runtime/connector.rs +++ b/src/runtime/connector.rs @@ -333,7 +333,7 @@ impl ConnectorPDL { return ConnectorScheduling::Immediate; }, - EvalContinuation::BlockGet(port_id) => { + EvalContinuation::BlockGet(_expr_id, port_id) => { // Branch performed a `get()` on a port that does not have a // received message on that port. let port_id = PortIdLocal::new(port_id.id); @@ -391,7 +391,7 @@ impl ConnectorPDL { let right_branch = &mut self.tree[right_id]; right_branch.prepared = PreparedStatement::ForkedExecution(false); } - EvalContinuation::Put(port_id, content) => { + EvalContinuation::Put(_expr_id, port_id, content) => { // Branch is attempting to send data let port_id = PortIdLocal::new(port_id.id); let (sync_header, data_header) = self.consensus.handle_message_to_send(branch_id, port_id, &content, comp_ctx);