mirror of
https://github.com/danswer-ai/danswer.git
synced 2025-10-10 21:26:01 +02:00
add minimal retries to confluence probe (#3222)
* add minimal retries to confluence probe * name variable correctly
This commit is contained in:
@@ -294,14 +294,17 @@ def _validate_connector_configuration(
|
|||||||
wiki_base: str,
|
wiki_base: str,
|
||||||
) -> None:
|
) -> None:
|
||||||
# test connection with direct client, no retries
|
# test connection with direct client, no retries
|
||||||
confluence_client_without_retries = Confluence(
|
confluence_client_with_minimal_retries = Confluence(
|
||||||
api_version="cloud" if is_cloud else "latest",
|
api_version="cloud" if is_cloud else "latest",
|
||||||
url=wiki_base.rstrip("/"),
|
url=wiki_base.rstrip("/"),
|
||||||
username=credentials["confluence_username"] if is_cloud else None,
|
username=credentials["confluence_username"] if is_cloud else None,
|
||||||
password=credentials["confluence_access_token"] if is_cloud else None,
|
password=credentials["confluence_access_token"] if is_cloud else None,
|
||||||
token=credentials["confluence_access_token"] if not is_cloud else None,
|
token=credentials["confluence_access_token"] if not is_cloud else None,
|
||||||
|
backoff_and_retry=True,
|
||||||
|
max_backoff_retries=6,
|
||||||
|
max_backoff_seconds=10,
|
||||||
)
|
)
|
||||||
spaces = confluence_client_without_retries.get_all_spaces(limit=1)
|
spaces = confluence_client_with_minimal_retries.get_all_spaces(limit=1)
|
||||||
|
|
||||||
if not spaces:
|
if not spaces:
|
||||||
raise RuntimeError(
|
raise RuntimeError(
|
||||||
|
Reference in New Issue
Block a user