From 13d1c8bb45052263a880ac343f0723e4c6839db1 Mon Sep 17 00:00:00 2001 From: Eric Hare Date: Mon, 22 Dec 2025 13:54:39 -0800 Subject: [PATCH] fix: Follow redirects for OneDrive + SharePoint --- src/connectors/onedrive/connector.py | 4 ++-- src/connectors/sharepoint/connector.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/connectors/onedrive/connector.py b/src/connectors/onedrive/connector.py index dcca775d..a902f577 100644 --- a/src/connectors/onedrive/connector.py +++ b/src/connectors/onedrive/connector.py @@ -394,7 +394,7 @@ class OneDriveConnector(BaseConnector): headers = {"Authorization": f"Bearer {token}"} async with httpx.AsyncClient() as client: - response = await client.get(url, headers=headers, timeout=60) + response = await client.get(url, headers=headers, timeout=60, follow_redirects=True) response.raise_for_status() return response.content @@ -406,7 +406,7 @@ class OneDriveConnector(BaseConnector): """Download file content from direct download URL.""" try: async with httpx.AsyncClient() as client: - response = await client.get(download_url, timeout=60) + response = await client.get(download_url, timeout=60, follow_redirects=True) response.raise_for_status() return response.content except Exception as e: diff --git a/src/connectors/sharepoint/connector.py b/src/connectors/sharepoint/connector.py index f9482d9c..1235a103 100644 --- a/src/connectors/sharepoint/connector.py +++ b/src/connectors/sharepoint/connector.py @@ -462,7 +462,7 @@ class SharePointConnector(BaseConnector): headers = {"Authorization": f"Bearer {token}"} async with httpx.AsyncClient() as client: - response = await client.get(url, headers=headers, timeout=60) + response = await client.get(url, headers=headers, timeout=60, follow_redirects=True) response.raise_for_status() return response.content @@ -535,7 +535,7 @@ class SharePointConnector(BaseConnector): """Download file content from direct download URL""" try: async with httpx.AsyncClient() as client: - response = await client.get(download_url, timeout=60) + response = await client.get(download_url, timeout=60, follow_redirects=True) response.raise_for_status() return response.content except Exception as e: