[ https://issues.apache.org/jira/browse/BEAM-7350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ashwin Ramaswami resolved BEAM-7350. ------------------------------------ Fix Version/s: 2.21.0 Resolution: Fixed The examples have been updated now. > Update Python Datastore example to use v1new Datastore IO > --------------------------------------------------------- > > Key: BEAM-7350 > URL: https://issues.apache.org/jira/browse/BEAM-7350 > Project: Beam > Issue Type: Improvement > Components: io-py-gcp > Reporter: Valentyn Tymofieiev > Assignee: niklas Hansson > Priority: P3 > Labels: stale-assigned > Fix For: 2.21.0 > > > Recently we updated Datastore IO implementation > https://github.com/apache/beam/pull/8262, and we need to update the example > to use the > new implementation. > Some pointers: > New IO: > https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/gcp/datastore/v1new/datastoreio.py > Old IO: > https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/gcp/datastore/v1/datastoreio.py > Example using old IO: > https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/cookbook/datastore_wordcount.py > Integration test using old IO: > https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/cookbook/datastore_wordcount_it_test.py > Once the integration test is using the new IO, we can also run it on Python3, > currently it is skipped: > https://github.com/apache/beam/blob/15deadff871e55676a5f708fee95b49d0688af83/sdks/python/apache_beam/examples/cookbook/datastore_wordcount_it_test.py#L37 > cc: [~udim] -- This message was sent by Atlassian Jira (v8.3.4#803005)