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

Minor fixes

Browse Source
This commit is contained in:
Honza Kral
2013-08-25 17:58:30 +02:00
parent 667160e9dc
commit 39bcd81957
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
elasticsearch/connection/thrift.py
+1
View File
@@ -1,3 +1,4 @@
from __future__ import absolute_import
import time import time
try: try:
test_elasticsearch/test_transport.py
+3 -3
View File
@@ -36,7 +36,7 @@ class TestTransport(TestCase):
def test_kwargs_passed_on_to_connections(self): def test_kwargs_passed_on_to_connections(self):
t = Transport([{'host': 'google.com'}], port=123) t = Transport([{'host': 'google.com'}], port=123)
self.assertEquals(1, len(t.connection_pool.connections)) self.assertEquals(1, len(t.connection_pool.connections))
self.assertEquals('http://google.com:123', t.connection_pool.connections[0].host) self.assertEquals('%s://google.com:123' % t.connection_pool.connections[0].transport_schema, t.connection_pool.connections[0].host)
def test_kwargs_passed_on_to_connection_pool(self): def test_kwargs_passed_on_to_connection_pool(self):
dt = object() dt = object()
@@ -53,10 +53,10 @@ class TestTransport(TestCase):
def test_add_connection(self): def test_add_connection(self):
t = Transport([{}], randomize_hosts=False) t = Transport([{}], randomize_hosts=False)
t.add_connection({"host": "google.com"}) t.add_connection({"host": "google.com", "port": 1234})
self.assertEquals(2, len(t.connection_pool.connections)) self.assertEquals(2, len(t.connection_pool.connections))
self.assertEquals('http://google.com:9200', t.connection_pool.connections[1].host) self.assertEquals('%s://google.com:1234' % t.connection_pool.connections[1].transport_schema, t.connection_pool.connections[1].host)
def test_request_will_fail_after_X_retries(self): def test_request_will_fail_after_X_retries(self):
t = Transport([{'exception': ConnectionError('abandon ship')}], connection_class=DummyConnection) t = Transport([{'exception': ConnectionError('abandon ship')}], connection_class=DummyConnection)