Update pg_replicate/src/clients/delta.rs

Co-authored-by: Raminder Singh <[email protected]>
supabase · Dec 17, 2024 · 8556582 · 8556582
1 parent 703254d
commit 8556582
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/pg_replicate/src/clients/delta.rs b/pg_replicate/src/clients/delta.rs
@@ -63,13 +63,10 @@ impl DeltaClient {
         }
     }
 
-    /// strips file:/// prefix from the uri
-    async fn strip_file_prefix(uri: &str) -> Result<&str, DeltaTableError> {
+    /// strips file:// prefix from the uri
+    fn strip_file_prefix(uri: &str) -> &str {
         if let Some(path) = uri.strip_prefix("file://") {
-            Ok(path)
-        } else if let Some(path) = uri.strip_prefix("s3://") {
-            let _ = path;
-            Ok(uri)
+            path
         } else {
             panic!("strip_file_prefix called on a non-file uri")
         }