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.
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
Add support for SEARCH commands in cluster #2042
Conversation
Codecov Report
@@ Coverage Diff @@
## master #2042 +/- ##
==========================================
+ Coverage 92.17% 92.19% +0.02%
==========================================
Files 100 100
Lines 20998 21027 +29
==========================================
+ Hits 19355 19386 +31
+ Misses 1643 1641 -2
Continue to review full report at Codecov.
|
@@ -318,6 +318,42 @@ class RedisCluster(RedisClusterCommands): | |||
), | |||
) | |||
|
|||
SEARCH_COMMANDS = ( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
When we refactor, the way commands like this work are on the table for change.
@@ -183,7 +183,7 @@ def wait_for_cluster_creation(redis_url, cluster_nodes, timeout=60): | |||
while now < end_time: | |||
try: | |||
client = redis.RedisCluster.from_url(redis_url) | |||
if len(client.get_nodes()) == cluster_nodes: | |||
if len(client.get_nodes()) == int(cluster_nodes): | |||
print("All nodes are available!") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we remove this print statement? In general, even in tests, we shouldn't have prints.
@@ -52,13 +48,12 @@ def waitForIndex(env, idx, timeout=None): | |||
break | |||
|
|||
|
|||
def getClient(): | |||
def getClient(client): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Great
Pull Request check-list
Please make sure to review and check all of these items:
$ tox
pass with this change (including linting)?NOTE: these things are not required to open a PR and can be done
afterwards / while the PR is open.
Description of change
Please provide a description of the change here.