You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by la...@apache.org on 2022/05/25 10:57:07 UTC
[incubator-pegasus] branch master updated: fix(python-cient): python3 pass str value but not bytes (#977)
This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new d6027a4f fix(python-cient): python3 pass str value but not bytes (#977)
d6027a4f is described below
commit d6027a4fb890a4a9d3532ad75407aa35d06ee28c
Author: Yingchun Lai <ac...@gmail.com>
AuthorDate: Wed May 25 18:56:59 2022 +0800
fix(python-cient): python3 pass str value but not bytes (#977)
---
python-client/pypegasus/pgclient.py | 6 +++---
rdsn | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/python-client/pypegasus/pgclient.py b/python-client/pypegasus/pgclient.py
index daf81480..457e99c8 100644
--- a/python-client/pypegasus/pgclient.py
+++ b/python-client/pypegasus/pgclient.py
@@ -844,7 +844,7 @@ class Pegasus(object):
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 @@ class Pegasus(object):
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 @@ class Pegasus(object):
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
index 3eb720b2..608c3cef 160000
--- a/rdsn
+++ b/rdsn
@@ -1 +1 @@
-Subproject commit 3eb720b28ae2739fc882243264eb0a917eeca459
+Subproject commit 608c3cef86b8789ef728781470bff45b9bad3a09
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org