use six.string_types instead of basestring
This commit is contained in:
parent
6eaea9aa6e
commit
b2af81eab5
@ -128,13 +128,13 @@ class Stream(object):
|
|||||||
raise ShardNotFoundError(shard_id)
|
raise ShardNotFoundError(shard_id)
|
||||||
|
|
||||||
def get_shard_for_key(self, partition_key, explicit_hash_key):
|
def get_shard_for_key(self, partition_key, explicit_hash_key):
|
||||||
if not isinstance(partition_key, basestring):
|
if not isinstance(partition_key, six.string_types):
|
||||||
raise InvalidArgumentError("partition_key")
|
raise InvalidArgumentError("partition_key")
|
||||||
if len(partition_key) > 256:
|
if len(partition_key) > 256:
|
||||||
raise InvalidArgumentError("partition_key")
|
raise InvalidArgumentError("partition_key")
|
||||||
|
|
||||||
if explicit_hash_key:
|
if explicit_hash_key:
|
||||||
if not isinstance(explicit_hash_key, basestring):
|
if not isinstance(explicit_hash_key, six.string_types):
|
||||||
raise InvalidArgumentError("explicit_hash_key")
|
raise InvalidArgumentError("explicit_hash_key")
|
||||||
|
|
||||||
key = int(explicit_hash_key)
|
key = int(explicit_hash_key)
|
||||||
|
Loading…
Reference in New Issue
Block a user