fix remaining usage of DateTime<Utc>

tursodatabase · Sep 18, 2024 · aeb495f · aeb495f
1 parent ccea285
commit aeb495f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/libsql-server/src/namespace/configurator/libsql_primary.rs b/libsql-server/src/namespace/configurator/libsql_primary.rs
@@ -269,7 +269,7 @@ impl ConfigureNamespace for LibsqlPrimaryConfigurator {
         _from_config: MetaStoreHandle,
         _to_ns: NamespaceName,
         _to_config: MetaStoreHandle,
-        _timestamp: Option<chrono::prelude::NaiveDateTime>,
+        timestamp: Option<chrono::prelude::NaiveDateTime>,
         _store: NamespaceStore,
     ) -> Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>> {
         Box::pin(async move {
@@ -283,7 +283,9 @@ impl ConfigureNamespace for LibsqlPrimaryConfigurator {
                                 .find_segment(
                                     &s.backend().default_config(),
                                     &ns,
-                                    libsql_wal::storage::backend::FindSegmentReq::Timestamp(ts),
+                                    libsql_wal::storage::backend::FindSegmentReq::Timestamp(
+                                        ts.and_utc(),
+                                    ),
                                 )
                                 .await
                                 .unwrap();

diff --git a/libsql-server/src/namespace/configurator/replica.rs b/libsql-server/src/namespace/configurator/replica.rs
@@ -2,7 +2,6 @@ use std::pin::Pin;
 use std::sync::atomic::AtomicBool;
 use std::sync::Arc;
 
-use chrono::{DateTime, Utc};
 use futures::Future;
 use hyper::Uri;
 use libsql_replication::rpc::replication::log_offset::WalFlavor;
@@ -256,7 +255,7 @@ impl ConfigureNamespace for ReplicaConfigurator {
         _from_config: MetaStoreHandle,
         _to_ns: NamespaceName,
         _to_config: MetaStoreHandle,
-        _timestamp: Option<DateTime<Utc>>,
+        _timestamp: Option<chrono::NaiveDateTime>,
         _store: NamespaceStore,
     ) -> Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>> {
         Box::pin(std::future::ready(Err(crate::Error::Fork(