Repository: beam Updated Branches: refs/heads/master affb926cc -> c81f83bc7
use custom hostname for datastore Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4a8547cd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4a8547cd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4a8547cd Branch: refs/heads/master Commit: 4a8547cd0b72d7ce92328002dc814034ce1502fa Parents: affb926 Author: Ahmet Altay <[email protected]> Authored: Wed Mar 29 18:00:16 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Fri Mar 31 13:40:51 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/gcp/datastore/v1/helper.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/4a8547cd/sdks/python/apache_beam/io/gcp/datastore/v1/helper.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/io/gcp/datastore/v1/helper.py b/sdks/python/apache_beam/io/gcp/datastore/v1/helper.py index 45c794f..b1ef9af 100644 --- a/sdks/python/apache_beam/io/gcp/datastore/v1/helper.py +++ b/sdks/python/apache_beam/io/gcp/datastore/v1/helper.py @@ -106,7 +106,7 @@ def str_compare(s1, s2): def get_datastore(project): """Returns a Cloud Datastore client.""" credentials = auth.get_service_credentials() - return Datastore(project, credentials) + return Datastore(project, credentials, host='batch-datastore.googleapis.com') def make_request(project, namespace, query):
