You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bh...@apache.org on 2022/08/31 01:31:45 UTC
[beam] branch master updated: Minor: Fix option_from_runner_api typehint (#22946)
This is an automated email from the ASF dual-hosted git repository.
bhulette 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 11e27427798 Minor: Fix option_from_runner_api typehint (#22946)
11e27427798 is described below
commit 11e27427798274ac09a36c9c65e55be79dd6b3a2
Author: Brian Hulette <bh...@google.com>
AuthorDate: Tue Aug 30 18:31:35 2022 -0700
Minor: Fix option_from_runner_api typehint (#22946)
---
sdks/python/apache_beam/typehints/schemas.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/typehints/schemas.py b/sdks/python/apache_beam/typehints/schemas.py
index dc572b4d07d..4b312d96ce9 100644
--- a/sdks/python/apache_beam/typehints/schemas.py
+++ b/sdks/python/apache_beam/typehints/schemas.py
@@ -178,7 +178,7 @@ def option_to_runner_api(
def option_from_runner_api(
option_proto: schema_pb2.Option,
- schema_registry: SchemaTypeRegistry = SCHEMA_REGISTRY) -> type:
+ schema_registry: SchemaTypeRegistry = SCHEMA_REGISTRY) -> Tuple[str, Any]:
return SchemaTranslation(
schema_registry=schema_registry).option_from_runner_api(option_proto)