[fix] Development

src/sinks.rs

@@ -1,6 +1,6 @@
 use crate::config::S3Config;
 use crate::error::Error;
-use crate::utils::FRAGMENT;
+use crate::utils::{bytes_to_key, FRAGMENT};
 use aws_credential_types::Credentials;
 use aws_sdk_s3::config::{BehaviorVersion, Region};
 use aws_sdk_s3::primitives::ByteStream;
@@ -59,7 +59,7 @@ impl Sink for S3Sink {
     async fn send(&self, key: &[u8], value: Vec<u8>) -> Result<(), Error> {
         // ToDo: Remove allocating and return stream
         // https://github.com/awslabs/aws-sdk-rust/discussions/361
-        let encoded_key = utf8_percent_encode(std::str::from_utf8(key).unwrap(), FRAGMENT)
+        let encoded_key = utf8_percent_encode(std::str::from_utf8(bytes_to_key(key)).unwrap(), FRAGMENT)
             .collect::<String>()
             .to_lowercase();
 

trident-py/trident/client.py

@@ -34,9 +34,12 @@ async def tables_create(self, table: str, storage: str | None = None) -> bytes:
         response = await self.post(url, params={'storage': storage})
         return await response.read()
 
-    async def tables_import(self, table: str, ticket: str, storage: str | None = None) -> bytes:
+    async def tables_import(self, table: str, ticket: str, storage: str | None = None, mirroring: dict | None = None) -> bytes:
         url = f"/tables/{table}/import/"
-        response = await self.post(url, params={'ticket': ticket, 'storage': storage})
+        response = await self.post(
+            url,
+            params={'ticket': ticket, 'storage': storage, 'mirroring': mirroring},
+        )
         return await response.read()
 
     async def tables_drop(self, table: str) -> bytes: