oauth refresh

Author: jordan-homan

unstructured_ingest/processes/connectors/fsspec/gcs.py

@@ -72,6 +72,12 @@ class GcsAccessConfig(FsspecAccessConfig):
         default=None, description=service_account_key_description
     )
     token: Union[str, dict, None] = Field(init=False, default=None)
+    refresh_token: Optional[str] = Field(
+        default=None,
+        description="OAuth 2.0 refresh token for obtaining new access tokens. "
+        "Long-lived; used by the platform to refresh expired access tokens "
+        "before each job run.",
+    )
 
     def model_post_init(self, __context: Any) -> None:
         ALLOWED_AUTH_VALUES = "google_default", "cache", "anon", "browser", "cloud"

unstructured_ingest/processes/connectors/google_drive.py

@@ -69,6 +69,12 @@ class GoogleDriveAccessConfig(AccessConfig):
         "Obtain via Google OAuth Playground or your OAuth application. "
         "Tokens typically expire after 1 hour.",
     )
+    refresh_token: Optional[str] = Field(
+        default=None,
+        description="OAuth 2.0 refresh token for obtaining new access tokens. "
+        "Long-lived; used by the platform to refresh expired access tokens "
+        "before each job run.",
+    )
 
     def model_post_init(self, __context: Any) -> None:
         has_service_account = (

unstructured_ingest/processes/connectors/onedrive.py

@@ -60,10 +60,15 @@ class OnedriveAccessConfig(AccessConfig):
         default=None,
         description=(
             "OAuth 2.0 access token for delegated user authentication. "
-            "Tokens typically expire after ~1 hour; this connector does not "
-            "refresh tokens."
+            "Tokens typically expire after ~1 hour."
         ),
     )
+    refresh_token: Optional[str] = Field(
+        default=None,
+        description="OAuth 2.0 refresh token for obtaining new access tokens. "
+        "Long-lived; used by the platform to refresh expired access tokens "
+        "before each job run.",
+    )
 
     def model_post_init(self, __context: Any) -> None:
         # Use truthiness so empty strings (e.g. from unset env vars) are treated

unstructured_ingest/processes/connectors/outlook.py

@@ -45,10 +45,15 @@ class OutlookAccessConfig(AccessConfig):
         default=None,
         description=(
             "OAuth 2.0 access token for delegated user authentication. "
-            "Tokens typically expire after ~1 hour; this connector does not "
-            "refresh tokens."
+            "Tokens typically expire after ~1 hour."
         ),
     )
+    refresh_token: Optional[str] = Field(
+        default=None,
+        description="OAuth 2.0 refresh token for obtaining new access tokens. "
+        "Long-lived; used by the platform to refresh expired access tokens "
+        "before each job run.",
+    )
 
     def model_post_init(self, __context: Any) -> None:
         # Use truthiness so empty strings (e.g. from unset env vars) are treated