File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -398,7 +398,7 @@ def getClusterConnectionIfNeeded(self):
398398 return self .getConnection ()
399399
400400 def waitCluster (self , timeout_sec = 40 ):
401- if isinstance (self .envRunner , ClusterEnv ) or isinstance ( self . envRunner , EnterpriseRedisClusterEnv ):
401+ if isinstance (self .envRunner , ( ClusterEnv , EnterpriseRedisClusterEnv ) ):
402402 self .envRunner .waitCluster (timeout_sec )
403403
404404 def addShardToClusterIfExists (self ):
Original file line number Diff line number Diff line change @@ -57,7 +57,7 @@ def _agreeOk(self):
5757 try :
5858 status = con .execute_command ('CLUSTER' , 'INFO' )
5959 except Exception as e :
60- print ('got error on cluster slots , will try again, %s' % str (e ))
60+ print ('got error on cluster info , will try again, %s' % str (e ))
6161 continue
6262 if 'cluster_state:ok' in str (status ):
6363 ok += 1
You can’t perform that action at this time.
0 commit comments