This is an automated email from the ASF dual-hosted git repository.
stankiewicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 4fd1744935c [Gemini] Fix pyrefly check unexpected-keyword (#39528)
4fd1744935c is described below
commit 4fd1744935c224e30919da668a4adf8dfaaf6c83
Author: Jack McCluskey <[email protected]>
AuthorDate: Wed Jul 29 05:47:03 2026 -0400
[Gemini] Fix pyrefly check unexpected-keyword (#39528)
* Fix pyrefly check unexpected-keyword
* fix field usage instead of adding a new field
---
.../examples/snippets/transforms/elementwise/enrichment_test.py | 2 +-
sdks/python/apache_beam/ml/inference/base.py | 2 +-
sdks/python/pyproject.toml | 1 -
3 files changed, 2 insertions(+), 3 deletions(-)
diff --git
a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py
b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py
index 0b356e03993..f37f297530c 100644
---
a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py
+++
b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py
@@ -380,7 +380,7 @@ class EnrichmentTestHelpers:
uri=db.uri,
user=db.user,
password=db.password,
- db_id=db.id,
+ db_name=db.id,
token=db.token)
collection_name = MilvusTestHelpers.initialize_db_with_data(
connection_params)
diff --git a/sdks/python/apache_beam/ml/inference/base.py
b/sdks/python/apache_beam/ml/inference/base.py
index 62c4047a961..84d68ef6c06 100644
--- a/sdks/python/apache_beam/ml/inference/base.py
+++ b/sdks/python/apache_beam/ml/inference/base.py
@@ -573,7 +573,7 @@ class _ModelHandlerManager:
# Map key for a model to a unique tag that will persist for the life of
# that model in memory. A new tag will be generated if a model is swapped
# out of memory and reloaded.
- self._tag_map: dict[str, str] = OrderedDict()
+ self._tag_map: OrderedDict[str, str] = OrderedDict()
# Map a tag to a multiprocessshared model object for that tag. Each entry
# of this map should last as long as the corresponding entry in _tag_map.
self._proxy_map: dict[str, multi_process_shared.MultiProcessShared] = {}
diff --git a/sdks/python/pyproject.toml b/sdks/python/pyproject.toml
index d8f09d7474b..a0c316f1b14 100644
--- a/sdks/python/pyproject.toml
+++ b/sdks/python/pyproject.toml
@@ -212,5 +212,4 @@ not-callable = "ignore"
invalid-argument = "ignore"
invalid-inheritance = "ignore"
not-iterable = "ignore"
-unexpected-keyword = "ignore"
bad-class-definition = "ignore"
