actions/opensearch-pyd
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Mark connection as dead even when sniffing to avoid using that host

Browse Source
This commit is contained in:
Honza Kral
2013-06-14 16:36:56 +02:00
parent 9c25f8cf01
commit 51486bec13
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
elasticsearch/transport.py
+2 -2
View File
@@ -184,10 +184,10 @@ class Transport(object):
:arg connection: instance of :class:`~elasticsearch.Connection` that failed :arg connection: instance of :class:`~elasticsearch.Connection` that failed
:arg dead_count: number of successive failures for this connection :arg dead_count: number of successive failures for this connection
""" """
# mark as dead even when sniffing to avoid hitting this host during the sniff process
self.connection_pool.mark_dead(connection, dead_count)
if self.sniff_on_connection_fail: if self.sniff_on_connection_fail:
self.sniff_hosts() self.sniff_hosts()
else:
self.connection_pool.mark_dead(connection, dead_count)
def perform_request(self, method, url, params=None, body=None): def perform_request(self, method, url, params=None, body=None):
""" """