Skip to content
Merged
Show file tree
Hide file tree
Changes from all 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


def test_valid_basic_send_request(mocker):
Expand Down
Loading