diff --git a/connectors/sources/box.py b/connectors/sources/box.py index 99bc7d985..52e2d4140 100644 --- a/connectors/sources/box.py +++ b/connectors/sources/box.py @@ -138,6 +138,7 @@ def __init__(self, configuration): self._logger = logger self.is_enterprise = configuration["is_enterprise"] self._http_session = aiohttp.ClientSession( + trust_env=True, base_url=BASE_URL, raise_for_status=True ) self.token = AccessToken( diff --git a/connectors/sources/confluence.py b/connectors/sources/confluence.py index 275d66db7..00e8a9210 100644 --- a/connectors/sources/confluence.py +++ b/connectors/sources/confluence.py @@ -156,6 +156,7 @@ def _get_session(self): basic_auth = aiohttp.BasicAuth(login=auth[0], password=auth[1]) timeout = aiohttp.ClientTimeout(total=None) # pyright: ignore self.session = aiohttp.ClientSession( + trust_env=True, auth=basic_auth, headers={ "accept": "application/json", diff --git a/connectors/sources/dropbox.py b/connectors/sources/dropbox.py index ab2956ea0..37ea5f41d 100644 --- a/connectors/sources/dropbox.py +++ b/connectors/sources/dropbox.py @@ -231,7 +231,11 @@ def _get_session(self): self._logger.debug("Generating aiohttp client session") timeout = aiohttp.ClientTimeout(total=None) - return aiohttp.ClientSession(timeout=timeout, raise_for_status=True) + return aiohttp.ClientSession( + trust_env=True, + timeout=timeout, + raise_for_status=True + ) async def close(self): self._sleeps.cancel() diff --git a/connectors/sources/github.py b/connectors/sources/github.py index 50bdc3d8b..ea6a64c16 100644 --- a/connectors/sources/github.py +++ b/connectors/sources/github.py @@ -737,6 +737,7 @@ def _get_session(self): connector = aiohttp.TCPConnector(ssl=self.ssl_ctx) timeout = aiohttp.ClientTimeout(total=None) return aiohttp.ClientSession( + trust_env=True, timeout=timeout, raise_for_status=True, connector=connector, diff --git a/connectors/sources/graphql.py b/connectors/sources/graphql.py index 4319d8d9f..990bdf43a 100644 --- a/connectors/sources/graphql.py +++ b/connectors/sources/graphql.py @@ -97,6 +97,7 @@ def session(self): } ) return aiohttp.ClientSession( + trust_env=True, headers=self.headers, timeout=timeout, raise_for_status=True, @@ -107,6 +108,7 @@ def session(self): password=self.configuration["password"], ) return aiohttp.ClientSession( + trust_env=True, auth=basic_auth, headers=self.headers, timeout=timeout, @@ -114,6 +116,7 @@ def session(self): ) else: return aiohttp.ClientSession( + trust_env=True, headers=self.headers, timeout=timeout, raise_for_status=True, diff --git a/connectors/sources/jira.py b/connectors/sources/jira.py index 0ceb9a55a..f624ede28 100644 --- a/connectors/sources/jira.py +++ b/connectors/sources/jira.py @@ -173,6 +173,7 @@ def _get_session(self): basic_auth = aiohttp.BasicAuth(login=login, password=password) timeout = aiohttp.ClientTimeout(total=None) # pyright: ignore self.session = aiohttp.ClientSession( + trust_env=True, auth=basic_auth, headers={ "accept": "application/json", diff --git a/connectors/sources/microsoft_teams.py b/connectors/sources/microsoft_teams.py index 15aecdffa..131a76049 100644 --- a/connectors/sources/microsoft_teams.py +++ b/connectors/sources/microsoft_teams.py @@ -364,6 +364,7 @@ class MicrosoftTeamsClient: def __init__(self, tenant_id, client_id, client_secret, username, password): self._sleeps = CancellableSleeps() self._http_session = aiohttp.ClientSession( + trust_env=True, headers={ "accept": "application/json", "content-type": "application/json", diff --git a/connectors/sources/notion.py b/connectors/sources/notion.py index c426bf82a..460b9982e 100644 --- a/connectors/sources/notion.py +++ b/connectors/sources/notion.py @@ -70,6 +70,7 @@ def session(self): connector = aiohttp.TCPConnector(limit=MAX_CONCURRENT_CLIENT_SUPPORT) return aiohttp.ClientSession( + trust_env=True, connector=connector, raise_for_status=True, ) diff --git a/connectors/sources/onedrive.py b/connectors/sources/onedrive.py index 7a8d08df2..03d03677d 100644 --- a/connectors/sources/onedrive.py +++ b/connectors/sources/onedrive.py @@ -249,6 +249,7 @@ def session(self): connector = aiohttp.TCPConnector(limit=DEFAULT_PARALLEL_CONNECTION_COUNT) timeout = aiohttp.ClientTimeout(total=REQUEST_TIMEOUT) return aiohttp.ClientSession( + trust_env=True, timeout=timeout, raise_for_status=True, connector=connector, diff --git a/connectors/sources/opentext_documentum.py b/connectors/sources/opentext_documentum.py index 96df5d24e..2472bc9db 100644 --- a/connectors/sources/opentext_documentum.py +++ b/connectors/sources/opentext_documentum.py @@ -98,6 +98,7 @@ def _get_session(self): auth = aiohttp.BasicAuth(login=login, password=password) timeout = aiohttp.ClientTimeout(total=None) return aiohttp.ClientSession( + trust_env=True, auth=auth, headers={ "content-type": "application/vnd.emc.documentum+json", diff --git a/connectors/sources/outlook.py b/connectors/sources/outlook.py index dc3c612a6..186ea3698 100644 --- a/connectors/sources/outlook.py +++ b/connectors/sources/outlook.py @@ -358,7 +358,10 @@ def __init__(self, client_id, client_secret, tenant_id): @cached_property def _get_session(self): - return aiohttp.ClientSession(raise_for_status=True) + return aiohttp.ClientSession( + trust_env=True, + raise_for_status=True + ) async def close(self): await self._get_session.close() diff --git a/connectors/sources/salesforce.py b/connectors/sources/salesforce.py index fe277110b..fabaee298 100644 --- a/connectors/sources/salesforce.py +++ b/connectors/sources/salesforce.py @@ -200,6 +200,7 @@ def set_logger(self, logger_): @cached_property def session(self): return aiohttp.ClientSession( + trust_env=True, timeout=aiohttp.ClientTimeout(total=None), ) diff --git a/connectors/sources/servicenow.py b/connectors/sources/servicenow.py index fc2632527..1dbd6dafd 100644 --- a/connectors/sources/servicenow.py +++ b/connectors/sources/servicenow.py @@ -134,6 +134,7 @@ def _get_session(self): timeout = aiohttp.ClientTimeout(total=None) # pyright: ignore return aiohttp.ClientSession( + trust_env=True, connector=connector, base_url=self.configuration["url"], auth=basic_auth, diff --git a/connectors/sources/sharepoint_online.py b/connectors/sources/sharepoint_online.py index 2306a4255..c913b2b05 100644 --- a/connectors/sources/sharepoint_online.py +++ b/connectors/sources/sharepoint_online.py @@ -526,6 +526,7 @@ def __init__(self, tenant_id, tenant_name, client_id, client_secret): # Change the value at your own risk tcp_connector = aiohttp.TCPConnector(limit=DEFAULT_PARALLEL_CONNECTION_COUNT) self._http_session = aiohttp.ClientSession( # TODO: lazy create this + trust_env=True, connector=tcp_connector, headers={ "accept": "application/json", diff --git a/connectors/sources/sharepoint_server.py b/connectors/sources/sharepoint_server.py index bc1e856ad..3f34df784 100644 --- a/connectors/sources/sharepoint_server.py +++ b/connectors/sources/sharepoint_server.py @@ -163,6 +163,7 @@ def _get_session(self): timeout = aiohttp.ClientTimeout(total=None) # pyright: ignore self.session = aiohttp.ClientSession( + trust_env=True, auth=aiohttp.BasicAuth( login=self.configuration["username"], password=self.configuration["password"], diff --git a/connectors/sources/slack.py b/connectors/sources/slack.py index 1152910de..6becb90aa 100644 --- a/connectors/sources/slack.py +++ b/connectors/sources/slack.py @@ -43,6 +43,7 @@ class SlackClient: def __init__(self, configuration): self.token = configuration["token"] self._http_session = aiohttp.ClientSession( + trust_env=True, headers=self._headers(), timeout=aiohttp.ClientTimeout(total=None), raise_for_status=True, diff --git a/connectors/sources/zoom.py b/connectors/sources/zoom.py index 76f09dade..72afd1b29 100644 --- a/connectors/sources/zoom.py +++ b/connectors/sources/zoom.py @@ -204,7 +204,10 @@ def __init__(self, configuration): self._logger = logger self.configuration = configuration - self.http_session = aiohttp.ClientSession(raise_for_status=True) + self.http_session = aiohttp.ClientSession( + trust_env=True, + raise_for_status=True + ) self.api_token = ZoomAPIToken( http_session=self.http_session,