Skip to content

Commit 35cbb56

Browse files
committed
[8.0] Require elastic-transport>=8.0.0b1
1 parent 0f7bff5 commit 35cbb56

File tree

4 files changed

+6
-4
lines changed

4 files changed

+6
-4
lines changed

dev-requirements.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
elastic-transport>=8.0.0a7, <9
1+
elastic-transport>=8.0.0b1, <9
22
requests>=2, <3
33
aiohttp
44
pytest

setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@
5151
if package == package_name or package.startswith(package_name + ".")
5252
]
5353

54-
install_requires = ["elastic-transport>=8.0.0a7,<9"]
54+
install_requires = ["elastic-transport>=8.0.0b1,<9"]
5555
async_requires = ["aiohttp>=3,<4"]
5656

5757
setup(

test_elasticsearch/test_async/test_transport.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525

2626
import pytest
2727
from elastic_transport import ApiResponseMeta, BaseAsyncNode, HttpHeaders, NodeConfig
28+
from elastic_transport._node import NodeApiResponse
2829
from elastic_transport.client_utils import DEFAULT
2930

3031
from elasticsearch import AsyncElasticsearch
@@ -55,7 +56,7 @@ async def perform_request(self, *args, **kwargs):
5556
self.calls.append((args, kwargs))
5657
if self.resp_error:
5758
raise self.resp_error
58-
return (
59+
return NodeApiResponse(
5960
ApiResponseMeta(
6061
status=self.resp_status,
6162
headers=HttpHeaders(self.resp_headers),

test_elasticsearch/test_transport.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323

2424
import pytest
2525
from elastic_transport import ApiResponseMeta, BaseNode, HttpHeaders, NodeConfig
26+
from elastic_transport._node import NodeApiResponse
2627
from elastic_transport.client_utils import DEFAULT
2728

2829
from elasticsearch import Elasticsearch, __versionstr__
@@ -51,7 +52,7 @@ def perform_request(self, *args, **kwargs):
5152
self.calls.append((args, kwargs))
5253
if self.resp_error:
5354
raise self.resp_error
54-
return (
55+
return NodeApiResponse(
5556
ApiResponseMeta(
5657
status=self.resp_status,
5758
headers=HttpHeaders(self.resp_headers),

0 commit comments

Comments
 (0)