busya/ss-tools
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(logging): suppress per-request belief scope spam in API client

Browse Source
This commit is contained in:
busya
2026-02-25 20:52:12 +03:00
parent 3801ca13d9
commit 4bad4ab4e2
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
backend/src/core/utils/network.py
View File

@@ -203,10 +203,9 @@ class APIClient:
# @PRE: APIClient is initialized and authenticated or can be authenticated. # @PRE: APIClient is initialized and authenticated or can be authenticated.
# @POST: Returns headers including auth tokens. # @POST: Returns headers including auth tokens.
def headers(self) -> Dict[str, str]: def headers(self) -> Dict[str, str]:
with belief_scope("headers"): if not self._authenticated:
if not self._authenticated: self.authenticate()
self.authenticate() return {
return {
"Authorization": f"Bearer {self._tokens['access_token']}", "Authorization": f"Bearer {self._tokens['access_token']}",
"X-CSRFToken": self._tokens.get("csrf_token", ""), "X-CSRFToken": self._tokens.get("csrf_token", ""),
"Referer": self.base_url, "Referer": self.base_url,
@@ -225,8 +224,7 @@ class APIClient:
# @RETURN: `requests.Response` если `raw_response=True`, иначе `dict`. # @RETURN: `requests.Response` если `raw_response=True`, иначе `dict`.
# @THROW: SupersetAPIError, NetworkError и их подклассы. # @THROW: SupersetAPIError, NetworkError и их подклассы.
def request(self, method: str, endpoint: str, headers: Optional[Dict] = None, raw_response: bool = False, **kwargs) -> Union[requests.Response, Dict[str, Any]]: def request(self, method: str, endpoint: str, headers: Optional[Dict] = None, raw_response: bool = False, **kwargs) -> Union[requests.Response, Dict[str, Any]]:
with belief_scope("request"): full_url = f"{self.base_url}{endpoint}"
full_url = f"{self.base_url}{endpoint}"
_headers = self.headers.copy() _headers = self.headers.copy()
if headers: if headers:
_headers.update(headers) _headers.update(headers)