Skip to content

Commit

Permalink
Still need to wait for PR restatedev#2172 to enable partition routing
Browse files Browse the repository at this point in the history
  • Loading branch information
slinkydeveloper committed Nov 1, 2024
1 parent 45b9913 commit 6761322
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions crates/core/src/network/partition_processor_rpc_client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ use restate_types::partition_table::{FindPartition, PartitionTable, PartitionTab
use crate::network::rpc_router::{ConnectionAwareRpcError, ConnectionAwareRpcRouter, RpcError};
use crate::network::{HasConnection, Networking, Outgoing, TransportConnect};
use crate::routing_info::PartitionRouting;
use crate::ShutdownError;
use crate::{metadata, ShutdownError};

#[derive(Debug, thiserror::Error)]
pub enum PartitionProcessorRpcClientError {
Expand Down Expand Up @@ -304,10 +304,12 @@ where
.pinned()
.find_partition_id(inner_request.partition_key())?;

let node_id = self
.partition_routing
.get_node_by_partition(partition_id)
.ok_or(PartitionProcessorRpcClientError::UnknownNode(partition_id))?;
// TODO enable it once https://github.com/restatedev/restate/pull/2172 goes in
// let node_id = self
// .partition_routing
// .get_node_by_partition(partition_id)
// .ok_or(PartitionProcessorRpcClientError::UnknownNode(partition_id))?;
let node_id = metadata().my_node_id();
let response = self
.rpc_router
.call(
Expand Down

0 comments on commit 6761322

Please sign in to comment.