Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion airbyte_cdk/sources/http_config.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,4 +7,4 @@
# order to fix that, we will increase the requests library pool_maxsize. As there are many pieces of code that sets a requests.Session, we
# are creating this variable here so that a change in one affects the other. This can be removed once we merge how we do HTTP requests in
# one piece of code or once we make connection pool size configurable for each piece of code
MAX_CONNECTION_POOL_SIZE = 20
MAX_CONNECTION_POOL_SIZE = 40
2 changes: 1 addition & 1 deletion unit_tests/sources/streams/http/test_http.py
Original file line number Diff line number Diff line change
Expand Up @@ -837,7 +837,7 @@ def test_duplicate_request_params_are_deduped(deduplicate_query_params, path, pa

def test_connection_pool():
stream = StubBasicReadHttpStream(authenticator=TokenAuthenticator("test-token"))
assert stream._http_client._session.adapters["https://"]._pool_connections == 20
assert stream._http_client._session.adapters["https://"]._pool_connections == 40
Comment thread
tolik0 marked this conversation as resolved.


class StubParentHttpStream(HttpStream, CheckpointMixin):
Expand Down
2 changes: 1 addition & 1 deletion unit_tests/sources/streams/http/test_http_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,7 @@ def test_connection_pool():
http_client = HttpClient(
name="test", logger=MagicMock(), authenticator=TokenAuthenticator("test-token")
)
assert http_client._session.adapters["https://"]._pool_connections == 20
assert http_client._session.adapters["https://"]._pool_connections == 40
Comment thread
tolik0 marked this conversation as resolved.


def test_valid_basic_send_request(mocker):
Expand Down
Loading