This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new cc9abce01b0 Add explicit type annotations to k8s code to fix mypy
(#64260)
cc9abce01b0 is described below
commit cc9abce01b07f8b12cf4c58383300c4be10a35d3
Author: Amogh Desai <[email protected]>
AuthorDate: Thu Mar 26 21:43:25 2026 +0530
Add explicit type annotations to k8s code to fix mypy (#64260)
---
.../src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
index 13926d0d386..23b4cc94b1f 100644
---
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
+++
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
@@ -1040,7 +1040,7 @@ class AsyncKubernetesHook(KubernetesHook):
# (e.g. binary data, truncated multi-byte sequences).
# kubernetes_asyncio's default decoding uses strict UTF-8 which
# crashes the task in those cases.
- kwargs = {
+ kwargs: dict[str, Any] = {
"name": name,
"namespace": namespace,
"follow": False,
@@ -1074,7 +1074,7 @@ class AsyncKubernetesHook(KubernetesHook):
async with self.get_conn() as connection:
try:
v1_api = async_client.CoreV1Api(connection)
- kwargs = {
+ kwargs: dict[str, Any] = {
"field_selector": f"involvedObject.name={name}",
"namespace": namespace,
}