This is an automated email from the ASF dual-hosted git repository.
altay 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 5a340c7 Fixed type on singleton side inputs sample
new 60fab9b Merge pull request #9195 from davidcavazos/filter-sample-fix
5a340c7 is described below
commit 5a340c7128434237dce108e30e9e407e7eb6b6a9
Author: David Cavazos <[email protected]>
AuthorDate: Tue Jul 30 13:59:11 2019 -0700
Fixed type on singleton side inputs sample
---
.../apache_beam/examples/snippets/transforms/element_wise/filter.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/sdks/python/apache_beam/examples/snippets/transforms/element_wise/filter.py
b/sdks/python/apache_beam/examples/snippets/transforms/element_wise/filter.py
index ded8af2..44b11b8 100644
---
a/sdks/python/apache_beam/examples/snippets/transforms/element_wise/filter.py
+++
b/sdks/python/apache_beam/examples/snippets/transforms/element_wise/filter.py
@@ -110,7 +110,7 @@ def filter_side_inputs_singleton(test=None):
{'icon': '🥔', 'name': 'Potato', 'duration': 'perennial'},
])
| 'Filter perennials' >> beam.Filter(
- lambda plant, duration: plant['duration'] >= duration,
+ lambda plant, duration: plant['duration'] == duration,
duration=beam.pvalue.AsSingleton(perennial),
)
| beam.Map(print)