health: move to mypy

.github/workflows/mypy.yml

@@ -0,0 +1,23 @@
+name: mypy validation
+
+on:
+  push:
+    branches: [main]
+  pull_request:
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    timeout-minutes: 5
+    strategy:
+      matrix:
+        python-version: ["3.13"]
+    steps:
+      - uses: actions/checkout@v4
+      - name: Set up Python ${{ matrix.python-version }}
+        uses: actions/setup-python@v5
+        with:
+          python-version: ${{ matrix.python-version }}
+      - name: Run mypy verification
+        run: |
+          ./scripts/run_mypy.sh

pyproject.toml

@@ -69,3 +69,11 @@ filterwarnings = [
 	"ignore:slack.* package is deprecated. Please use slack_sdk.* package instead.*:UserWarning",
 ]
 asyncio_mode = "auto"
+
+
+[tool.mypy]
+files = "slack_sdk/"
+exclude = ["slack_sdk/scim", "slack_sdk/rtm"]
+force_union_syntax = true
+warn_unused_ignores = true
+enable_error_code = "ignore-without-code"

requirements/testing.txt

@@ -16,3 +16,4 @@ psutil>=6.0.0,<7
 boto3<=2
 # For AWS tests
 moto>=4.0.13,<6
+mypy<=1.13.0

scripts/run_mypy.sh

@@ -0,0 +1,13 @@
+#!/bin/bash
+# ./scripts/run_mypy.sh
+
+set -e
+
+script_dir=$(dirname $0)
+cd ${script_dir}/..
+
+pip install -U pip setuptools wheel
+pip install -r requirements/testing.txt \
+  -r requirements/optional.txt
+
+mypy --config-file pyproject.toml

slack_sdk/audit_logs/v1/async_client.py

@@ -2,6 +2,7 @@
 
 Refer to https://slack.dev/python-slack-sdk/audit-logs/ for details.
 """
+
 import json
 import logging
 from ssl import SSLContext
@@ -225,7 +226,7 @@
         headers: Dict[str, str],
     ) -> AuditLogsResponse:
         if body_params is not None:
-            body_params = json.dumps(body_params)
+            body_params = json.dumps(body_params)  # type: ignore[assignment]
         headers["Content-Type"] = "application/json;charset=utf-8"
 
         session: Optional[ClientSession] = None
@@ -252,7 +253,7 @@
             retry_request = RetryHttpRequest(
                 method=http_verb,
                 url=url,
-                headers=headers,
+                headers=headers,  # type: ignore[arg-type]
                 body_params=body_params,
             )
 
@@ -278,19 +279,19 @@
                     )
 
                 try:
-                    async with session.request(http_verb, url, **request_kwargs) as res:
+                    async with session.request(http_verb, url, **request_kwargs) as res:  # type: ignore[arg-type, union-attr] # noqa: E501
                         try:
                             response_body = await res.text()
                             retry_response = RetryHttpResponse(
                                 status_code=res.status,
-                                headers=res.headers,
+                                headers=res.headers,  # type: ignore[arg-type]
                                 data=response_body.encode("utf-8") if response_body is not None else None,
                             )
                         except aiohttp.ContentTypeError:
                             self.logger.debug(f"No response data returned from the following API call: {url}.")
                             retry_response = RetryHttpResponse(
                                 status_code=res.status,
-                                headers=res.headers,
+                                headers=res.headers,  # type: ignore[arg-type]
                             )
                         except json.decoder.JSONDecodeError as e:
                             message = f"Failed to parse the response body: {str(e)}"
@@ -320,7 +321,7 @@
                                 url=url,
                                 status_code=res.status,
                                 raw_body=response_body,
-                                headers=res.headers,
+                                headers=res.headers,  # type: ignore[arg-type]
                             )
                             _debug_log_response(self.logger, resp)
                             return resp
@@ -351,10 +352,10 @@
 
             if resp is not None:
                 return resp
-            raise last_error
+            raise last_error  # type: ignore[misc]
 
         finally:
             if not use_running_session:
-                await session.close()
+                await session.close()  # type: ignore[union-attr]
 
         return resp

slack_sdk/audit_logs/v1/client.py

@@ -2,6 +2,7 @@
 
 Refer to https://slack.dev/python-slack-sdk/audit-logs/ for details.
 """
+
 import json
 import logging
 import urllib
@@ -217,7 +218,7 @@
         headers: Dict[str, str],
     ) -> AuditLogsResponse:
         if body is not None:
-            body = json.dumps(body)
+            body = json.dumps(body)  # type: ignore[assignment]
         headers["Content-Type"] = "application/json;charset=utf-8"
 
         if self.logger.level <= logging.DEBUG:
@@ -229,7 +230,7 @@
         req = Request(
             method=http_verb,
             url=url,
-            data=body.encode("utf-8") if body is not None else None,
+            data=body.encode("utf-8") if body is not None else None,  # type: ignore[attr-defined]
             headers=headers,
         )
         resp = None
@@ -327,7 +328,7 @@
 
         if resp is not None:
             return resp
-        raise last_error
+        raise last_error  # type: ignore[misc]
 
     def _perform_http_request_internal(self, url: str, req: Request) -> AuditLogsResponse:
         opener: Optional[OpenerDirector] = None
@@ -344,19 +345,18 @@
         else:
             raise SlackRequestError(f"Invalid URL detected: {url}")
 
-        # NOTE: BAN-B310 is already checked above
-        http_resp: Optional[HTTPResponse] = None
+        http_resp: HTTPResponse
         if opener:
-            http_resp = opener.open(req, timeout=self.timeout)  # skipcq: BAN-B310
+            http_resp = opener.open(req, timeout=self.timeout)
         else:
-            http_resp = urlopen(req, context=self.ssl, timeout=self.timeout)  # skipcq: BAN-B310
+            http_resp = urlopen(req, context=self.ssl, timeout=self.timeout)
         charset: str = http_resp.headers.get_content_charset() or "utf-8"
         response_body: str = http_resp.read().decode(charset)
         resp = AuditLogsResponse(
             url=url,
             status_code=http_resp.status,
             raw_body=response_body,
-            headers=http_resp.headers,
+            headers=http_resp.headers,  # type: ignore[arg-type]
         )
         _debug_log_response(self.logger, resp)
         return resp

slack_sdk/audit_logs/v1/logs.py

@@ -804,7 +804,7 @@
             self.attributes = []
             for a in attributes:
                 if isinstance(a, dict):
-                    self.attributes.append(Attribute(**a))
+                    self.attributes.append(Attribute(**a))  # type: ignore[arg-type]
                 else:
                     self.attributes.append(a)
         self.channel = channel
@@ -822,11 +822,11 @@
         self.rules_checked = None
         if rules_checked is not None:
             self.rules_checked = []
-            for a in rules_checked:
+            for a in rules_checked:  # type: ignore[assignment]
                 if isinstance(a, dict):
-                    self.rules_checked.append(AAARule(**a))
+                    self.rules_checked.append(AAARule(**a))  # type: ignore[arg-type]
                 else:
-                    self.rules_checked.append(a)
+                    self.rules_checked.append(a)  # type: ignore[arg-type]
         self.disconnecting_team = disconnecting_team
         self.is_channel_canvas = is_channel_canvas
         self.linked_channel_id = linked_channel_id
@@ -1021,7 +1021,7 @@
 class WorkflowV2StepConfiguration:
     name: Optional[str]
     step_function_type: Optional[str]
-    step_function_app_id: Optional[int]
+    step_function_app_id: Optional[str]
     unknown_fields: Dict[str, Any]
 
     def __init__(
@@ -1235,7 +1235,7 @@
         provided: Optional[str] = None,
         **kwargs,
     ) -> None:
-        self.entries = [Entry(**e) if isinstance(e, dict) else e for e in entries]
+        self.entries = [Entry(**e) if isinstance(e, dict) else e for e in entries]  # type: ignore[union-attr]
         self.response_metadata = (
             ResponseMetadata(**response_metadata) if isinstance(response_metadata, dict) else response_metadata
         )

slack_sdk/audit_logs/v1/response.py

@@ -13,8 +13,8 @@ class AuditLogsResponse:
     body: Optional[Dict[str, Any]]
     typed_body: Optional[LogsResponse]
 
-    @property
-    def typed_body(self) -> Optional[LogsResponse]:  # type: ignore
+    @property  # type: ignore[no-redef]
+    def typed_body(self) -> Optional[LogsResponse]:
         if self.body is None:
             return None
         return LogsResponse(**self.body)

slack_sdk/http_retry/builtin_async_handlers.py

@@ -68,7 +68,7 @@
         error: Optional[Exception] = None,
     ) -> None:
         if response is None:
-            raise error
+            raise error  # type: ignore[misc]
 
         state.next_attempt_requested = True
         retry_after_header_name: Optional[str] = None
@@ -79,9 +79,9 @@
         duration = 1
         if retry_after_header_name is None:
             # This situation usually does not arise. Just in case.
-            duration += random.random()
+            duration += random.random()  # type: ignore[assignment]
         else:
-            duration = int(response.headers.get(retry_after_header_name)[0]) + random.random()
+            duration = int(response.headers.get(retry_after_header_name)[0]) + random.random()  # type: ignore[assignment, index] # noqa: E501
         await asyncio.sleep(duration)
         state.increment_current_attempt()
 

slack_sdk/http_retry/builtin_handlers.py

@@ -71,7 +71,7 @@
         error: Optional[Exception] = None,
     ) -> None:
         if response is None:
-            raise error
+            raise error  # type: ignore[misc]
 
         state.next_attempt_requested = True
         retry_after_header_name: Optional[str] = None
@@ -82,9 +82,9 @@
         duration = 1
         if retry_after_header_name is None:
             # This situation usually does not arise. Just in case.
-            duration += random.random()
+            duration += random.random()  # type: ignore[assignment]
         else:
-            duration = int(response.headers.get(retry_after_header_name)[0]) + random.random()
+            duration = int(response.headers.get(retry_after_header_name)[0]) + random.random()  # type: ignore[index, assignment] # noqa: E501
         time.sleep(duration)
         state.increment_current_attempt()
 

slack_sdk/http_retry/request.py

@@ -29,8 +29,8 @@ def __init__(
     @classmethod
     def from_urllib_http_request(cls, req: Request) -> "HttpRequest":
         return HttpRequest(
-            method=req.method,
+            method=req.method,  # type: ignore[arg-type]
             url=req.full_url,
             headers={k: v if isinstance(v, list) else [v] for k, v in req.headers.items()},
-            data=req.data,
+            data=req.data,  # type: ignore[arg-type]
         )

slack_sdk/http_retry/response.py

@@ -5,7 +5,7 @@ class HttpResponse:
     """HTTP response representation"""
 
     status_code: int
-    headers: Dict[str, List[str]]
+    headers: Dict[str, Union[List[str], str]]
     body: Optional[Dict[str, Any]]
     data: Optional[bytes]
 

slack_sdk/models/__init__.py

@@ -12,7 +12,7 @@
 # NOTE: used only for legacy components - don't use this for Block Kit
 def extract_json(
     item_or_items: Union[JsonObject, Sequence[JsonObject]], *format_args
-) -> Union[Dict[Any, Any], List[Dict[Any, Any]]]:  # type: ignore
+) -> Union[Dict[Any, Any], List[Dict[Any, Any]], Sequence[JsonObject]]:
     """
     Given a sequence (or single item), attempt to call the to_dict() method on each
     item and return a plain list. If item is not the expected type, return it
@@ -24,13 +24,12 @@ def extract_json(
             method
     """
     try:
-        return [  # type: ignore
-            elem.to_dict(*format_args) if isinstance(elem, JsonObject) else elem for elem in item_or_items
+        return [
+            elem.to_dict(*format_args) if isinstance(elem, JsonObject) else elem
+            for elem in item_or_items  # type: ignore[union-attr]
         ]
     except TypeError:  # not iterable, so try returning it as a single item
-        return (  # type: ignore
-            item_or_items.to_dict(*format_args) if isinstance(item_or_items, JsonObject) else item_or_items
-        )
+        return item_or_items.to_dict(*format_args) if isinstance(item_or_items, JsonObject) else item_or_items
 
 
 def show_unknown_key_warning(name: Union[str, object], others: dict):

slack_sdk/models/attachments/__init__.py

@@ -42,7 +42,7 @@ def __init__(
     def name_or_url_present(self):
         return self.name is not None or self.url is not None
 
-    def to_dict(self) -> dict:  # skipcq: PYL-W0221
+    def to_dict(self) -> dict:
         json = super().to_dict()
         json["type"] = self.subtype
         return json
@@ -212,7 +212,7 @@ class ActionExternalSelector(AbstractActionSelector):
     data_source = "external"
 
     @property
-    def attributes(self) -> Set[str]:
+    def attributes(self) -> Set[str]:  # type: ignore[override]
         return super().attributes.union({"min_query_length"})
 
     def __init__(
@@ -417,7 +417,7 @@ def author_link_without_author_name(self) -> bool:
     def author_link_without_author_icon(self) -> bool:
         return self.author_link is None or self.author_icon is not None
 
-    def to_dict(self) -> dict:  # skipcq: PYL-W0221
+    def to_dict(self) -> dict:
         json = super().to_dict()
         if self.fields is not None:
             json["fields"] = extract_json(self.fields)
@@ -469,7 +469,7 @@ def to_dict(self) -> dict:
 
 class InteractiveAttachment(Attachment):
     @property
-    def attributes(self) -> Set[str]:
+    def attributes(self) -> Set[str]:  # type: ignore[override]
         return super().attributes.union({"callback_id"})
 
     actions_max_length = 5