This is an automated email from the ASF dual-hosted git repository.
vavila pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/superset.git
The following commit(s) were added to refs/heads/master by this push:
new 05409d51da feat(slack): adds rate limit error handler for Slack client
(#32510)
05409d51da is described below
commit 05409d51da0b60fe6898c44ac6db0dcf720f90fd
Author: Usiel Riedl <[email protected]>
AuthorDate: Thu Mar 6 19:01:12 2025 +0800
feat(slack): adds rate limit error handler for Slack client (#32510)
---
superset/utils/slack.py | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/superset/utils/slack.py b/superset/utils/slack.py
index 468429fb60..b4c8018ffc 100644
--- a/superset/utils/slack.py
+++ b/superset/utils/slack.py
@@ -22,6 +22,7 @@ from typing import Optional
from flask import current_app
from slack_sdk import WebClient
from slack_sdk.errors import SlackApiError
+from slack_sdk.http_retry.builtin_handlers import RateLimitErrorRetryHandler
from superset import feature_flag_manager
from superset.exceptions import SupersetException
@@ -43,7 +44,12 @@ def get_slack_client() -> WebClient:
token: str = current_app.config["SLACK_API_TOKEN"]
if callable(token):
token = token()
- return WebClient(token=token, proxy=current_app.config["SLACK_PROXY"])
+ client = WebClient(token=token, proxy=current_app.config["SLACK_PROXY"])
+
+ rate_limit_handler = RateLimitErrorRetryHandler(max_retry_count=2)
+ client.retry_handlers.append(rate_limit_handler)
+
+ return client
def get_channels_with_search(
