Always return my_node_id()

restatedev · Oct 16, 2024 · 3b28c35 · 3b28c35
1 parent e2b6628
commit 3b28c35
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/crates/storage-query-datafusion/src/remote_query_scanner_manager.rs b/crates/storage-query-datafusion/src/remote_query_scanner_manager.rs
@@ -13,12 +13,12 @@ use std::fmt::{Debug, Formatter};
 use std::ops::RangeInclusive;
 use std::sync::{Arc, Mutex};
 
-use datafusion::arrow::datatypes::SchemaRef;
-use datafusion::execution::SendableRecordBatchStream;
-
 use crate::partition_store_scanner::RemotePartitionsScanner;
 use crate::remote_query_scanner_client::RemoteScannerService;
 use crate::table_providers::ScanPartition;
+use datafusion::arrow::datatypes::SchemaRef;
+use datafusion::execution::SendableRecordBatchStream;
+use restate_core::my_node_id;
 use restate_types::identifiers::{PartitionId, PartitionKey};
 use restate_types::NodeId;
 
@@ -107,7 +107,7 @@ impl RemoteScannerManager {
 
     pub fn get_partition_target_node(&self, _partition_id: PartitionId) -> NodeId {
         // TODO: obtain this information somehow
-        todo!()
+        my_node_id().into()
     }
 }