fix(python-cient): python3 pass str value but not bytes (#977)

apache · May 25, 2022 · d6027a4 · d6027a4
1 parent cedb819
commit d6027a4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/python-client/pypegasus/pgclient.py b/python-client/pypegasus/pgclient.py
@@ -844,7 +844,7 @@ def multi_set(self, hash_key, sortkey_value_dict, ttl=0, timeout=0):
         partition_hash = self.table.get_hashkey_hash(hash_key)
         peer_gpid = self.table.get_gpid_by_hash(partition_hash)
         session = self.table.get_session(peer_gpid)
-        kvs = [key_value(blob(str(k)), blob(str(v))) for k, v in sortkey_value_dict.items()]
+        kvs = [key_value(blob(k), blob(v)) for k, v in sortkey_value_dict.items()]
         ttl = get_ttl(ttl)
         req = multi_put_request(blob(hash_key), kvs, ttl)
         op = RrdbMultiPutOperator(peer_gpid, req, partition_hash)
@@ -881,7 +881,7 @@ def multi_get(self, hash_key,
         if sortkey_set is None:
             pass
         elif isinstance(sortkey_set, set):
-            ks = [blob(str(k)) for k in sortkey_set]
+            ks = [blob(k) for k in sortkey_set]
         else:
             return error_types.ERR_INVALID_PARAMETERS.value, 0
 
@@ -976,7 +976,7 @@ def multi_del(self, hash_key, sortkey_set, timeout=0):
         session = self.table.get_session(peer_gpid)
         ks = []
         if isinstance(sortkey_set, set):
-            ks = [blob(str(k)) for k in sortkey_set]
+            ks = [blob(k) for k in sortkey_set]
         else:
             return error_types.ERR_INVALID_PARAMETERS.value, 0
 

diff --git a/rdsn b/rdsn
+10 −2		src/meta/meta_bulk_load_service.cpp
+1 −0		src/meta/meta_bulk_load_service.h
+1 −4		src/meta/test/meta_bulk_load_service_test.cpp
+19 −4		src/replica/bulk_load/replica_bulk_loader.cpp
+1 −1		src/replica/bulk_load/replica_bulk_loader.h