add retries to sharepoint connection queries (#9831)

GitOrigin-RevId: ce38f3a8642372741734be6692565f9c19351941

Author: zxqfd555

CHANGELOG.md

@@ -11,6 +11,9 @@ This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm
 - Workers can now automatically scale up or down based on pipeline load, using a configurable monitoring window. This feature requires persistence to be enabled and can be configured via `worker_scaling_enabled` and `workload_tracking_window_ms` in `pw.persistence.Config`. Please refer to the tutorial for more details.
 - `pw.io.postgres.write` now properly supports TLS configuration via `sslmode` and `sslrootcert` connection string parameters.
 
+### Changelog
+- `pw.xpacks.connectors.read` now retries initial connection requests.
+
 ## [0.29.0] - 2026-01-22
 
 ### Added

python/pathway/xpacks/connectors/sharepoint/__init__.py

@@ -105,7 +105,7 @@ def get_snapshot_diff(self):
         root_folder = self._context.web.get_folder_by_server_relative_path(
             self._root_path
         )
-        files = root_folder.get_files(self._recursive).execute_query()
+        files = root_folder.get_files(self._recursive).execute_query_retry()
 
         updated_entries = []
         deleted_entries = []
@@ -128,7 +128,7 @@ def get_snapshot_diff(self):
                 if size_limit_exceeded:
                     content = b""
                 else:
-                    content = file.get_content().execute_query().value
+                    content = file.get_content().execute_query_retry().value
                 updated_entries.append((content, metadata))
                 self._stored_metadata[metadata.path] = metadata
             seen_objects.add(metadata.path)
@@ -247,7 +247,7 @@ def context(self):
         )
         current_web = context.web
         context.load(current_web)
-        context.execute_query()
+        context.execute_query_retry()
         return context