Skip to content

BugFix: "Transport endpoint is not connected" #34

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Anton-Shutik wants to merge 5 commits into
base: master
Choose a base branch
from
Open

BugFix: "Transport endpoint is not connected" #34

Changes from 1 commit
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
6728c13
Store client in thread safe way
Anton-Shutik Jun 10, 2021
d55062b
Use BaseMemcachedCache as base class
Anton-Shutik Jun 10, 2021
abdffea
Fixed test
Anton-Shutik Jun 18, 2021
53f608a
Replaced smart_text with smart_str
Anton-Shutik Feb 6, 2024
effef96
Merge pull request #2 from groveco/fix-import
Anton-Shutik Feb 6, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Replaced smart_text with smart_str
  • Loading branch information
@Anton-Shutik
Anton-Shutik committed Feb 6, 2024
commit 53f608a33e2b1503afb398e8953e156a68aeb2ba
12 changes: 6 additions & 6 deletions django_elasticache/cluster_utils.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
utils for discovery cluster
"""
from distutils.version import StrictVersion
from django.utils.encoding import smart_text
from django.utils.encoding import smart_str
import re
from telnetlib import Telnet

Expand Down Expand Up @@ -35,7 +35,7 @@ def get_cluster_info(host, port, ignore_cluster_errors=False):
if len(version_list) not in [2, 3] or version_list[0] != b'VERSION':
raise WrongProtocolData('version', res)
version = version_list[1]
if StrictVersion(smart_text(version)) >= StrictVersion('1.4.14'):
if StrictVersion(smart_str(version)) >= StrictVersion('1.4.14'):
cmd = b'config get cluster\n'
else:
cmd = b'get AmazonElastiCache:cluster\n'
Expand All @@ -50,8 +50,8 @@ def get_cluster_info(host, port, ignore_cluster_errors=False):
return {
'version': version,
'nodes': [
'{0}:{1}'.format(smart_text(host),
smart_text(port))
'{0}:{1}'.format(smart_str(host),
smart_str(port))
]
}

Expand All @@ -67,8 +67,8 @@ def get_cluster_info(host, port, ignore_cluster_errors=False):
try:
for node in ls[2].split(b' '):
host, ip, port = node.split(b'|')
nodes.append('{0}:{1}'.format(smart_text(ip or host),
smart_text(port)))
nodes.append('{0}:{1}'.format(smart_str(ip or host),
smart_str(port)))
except ValueError:
raise WrongProtocolData(cmd, res)
return {
Expand Down