Skip to content
代码片段 群组 项目
未验证 提交 4a5a0076 编辑于 作者: Hai Joey Tran's avatar Hai Joey Tran 提交者: GitHub
浏览文件

Update translations_test.py

上级 f37d8601
No related branches found
No related tags found
无相关合并请求
......@@ -392,11 +392,11 @@ class TranslationsTest(unittest.TestCase):
class MyCombinePerKey(beam.CombinePerKey):
def annotations(self):
return {"my_annotation":b""}
# Verify the results are as expected.
with TestPipeline() as pipeline:
pipeline | beam.Create([(1, 2)]) | MyCombinePerKey(min)
# Verify the optimization is as expected.
# Verify the annotations are propagated to the split up
# CPK transforms
proto = pipeline.to_runner_api(
default_environment=environments.EmbeddedPythonEnvironment(
capabilities=environments.python_sdk_capabilities()))
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册