Updating datastore system test to allow concurrent runs.

Using a namespace for any key which is changed (inserted/deleted)
so that concurrent tests don't operate on the same data. The
one exception is `TestDatastoreQuery` which depends on entities
which need to be already stored and indexed before running. For
this test case, a new client is created without any namespace.

system_tests/danielhermes-gcloud-research-890954bc98d1.json

@@ -0,0 +1,11 @@
+{
+  "type": "service_account",
+  "private_key_id": "890954bc98d1d3fa88f2e0809846889fa0990f1d",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCWs7n8VH/zYDdM\nmk02357GxGyiPLakgjzgYQ7KPJsFo7ZtFM03cdF7p+3azkcxL/R4NnWdnq259mYY\nHeEp9szmovnicmTfnY53iJifiXgr6C83ezb9npP2Vq+eMEUGoP+npXW8kk/Dkald\n5VUkMXM4vDDpPVdreTpOg1FQ33zUhI/X9dnkTdyYKHgx6OhhfnxMWbYcRr7IsVHp\nVgx7/M8hcRRWLwaAx5ItUv0iYVoVFKGtz7OKIzODjpHNadc0BmasAYxgasAxC6TT\nPLMxsIgjGnaEIaQunXWbR9ezVP993izTjUkBzqFQZWnS1hhM4yOhmTVeM59sTXX8\nxsbpt8JdAgMBAAECggEAdwpRB3jX+S8vf1sDUy0hBnFyPlUnEJuv6q3AOQ/WhIXl\nPBUKZZmKl9r2j7gRlFEFE1AxZ+hH4nU4ACTaD4PcJvLl4HHsLJcQSmuj46F7Q3OM\nmI7DyWLSDew7nQEUBUB3sb2JWwNX7mvJFVpp/sTw9wfwusyxmTuRSyN/wBpJSLSX\nezegkaKI4zraUfH2P54yeBoTX06WjrQWX9qUadjOGW9n2Cib52b+yJua/Ge+Gch/\nFtnTM2ezLSH0Y/GSmqKD8Vyk+/HptQLIhWov2cptn70k1jPqiZjG787fJhlfzY41\nhkMxoRTNkfOa9mLa8IGZxqJXNxoDtzwlhNl4xzKpAQKBgQDFqBIPFrZgzb8014Xk\npR1QbcCKQBxtwmeE40k106PN3ky3PVb3r05aUH0z87BiyEX19Vrv8iuCyIK0qcvi\nZXaa5Jter/RK+PKaMfNbQBEwVQOGurU5eYuHxaQoGrhZx2OCp0/4NPmemZV0H/T0\nlHL3Ynxkmv34typ6SU9np4MUeQKBgQDDL4nFnUWywIq+cYxlAkMYN0+6jNXnVKVR\n+BSSRiu1LNeHlnzjk/EOzNcxOmNLjsM7uepUXIhLEwFBAHUOqLdI+H3YHZ4H1oSU\nsoWRrvNfqr9xxKIEuyVj9g0Ath81mhWIAmt75o33Kx3Aju3fJPiv3X6zSEl/OCns\nJgpQVzw8BQKBgFfUoYG28//8LVUL2GGLxYTx4DcO2hMj6eAxJ10V2JooiCp8xWJ2\nsfiL/7bQOLcMi5oKFwi8sf0BoKMrOIA32gZmQ2xF/+Y4zYUbYSpRQ9IYVOLPoKwT\niJ8ighmYFgc/BMcQFgcTc0C4uqLJeI4eUSAA0YnbHbQhoGyKmxBSbXrxAoGAeXDy\nf4nC+9zgdm2ftJkbtc10RdWqoSwBUGbSJdCTET69OxdezRoXOeYpXe++KBzDTD34\nllScWFmSxibKrjw7DaPOaNDEqovGId6RTHtV4YgTZW26gMcQFInavT6TXH5qNx2K\nUqS4X7jr4gsL5XLTaFifpFytngIL02o3sJUWXSECgYBJ4W3E5JiypGP/X8J6RXeL\nKfmBzMXgXnSFap5Q1RrSifL0jNH4HEP4UqsUx7+veUWIHoL1Db51HXCudHRKWYcU\n6RO2K5Unh3ALrRD4RRlKHWzEiLeVPysYIuXN6dRQnoIzld/mBPaNutbA0/Er9wr1\nBA+YZ1PHFdEVk024eyV5iQ==\n-----END PRIVATE KEY-----\n",
+  "client_email": "522695182322-uld8n1q3nrar5r6k3nk249fvppes5u73@developer.gserviceaccount.com",
+  "client_id": "522695182322-uld8n1q3nrar5r6k3nk249fvppes5u73.apps.googleusercontent.com",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://accounts.google.com/o/oauth2/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/522695182322-uld8n1q3nrar5r6k3nk249fvppes5u73%40developer.gserviceaccount.com"
+}

system_tests/datastore.py

@@ -14,12 +14,13 @@
 
 import datetime
 import os
+import time
 
 import unittest2
 
 from gcloud._helpers import UTC
 from gcloud import datastore
-from gcloud.datastore import client
+from gcloud.datastore import client as client_mod
 from gcloud.environment_vars import GCD_DATASET
 from gcloud.environment_vars import TESTS_DATASET
 from gcloud.exceptions import Conflict
@@ -29,6 +30,8 @@
 from system_tests import populate_datastore
 
 
+# Isolated namespace so concurrent test runs don't collide.
+TEST_NAMESPACE = 'ns%d' % (1000 * time.time(),)
 EMULATOR_DATASET = os.getenv(GCD_DATASET)
 
 
@@ -41,18 +44,22 @@ class Config(object):
     CLIENT = None
 
 
+def clone_client(client):
+    # Fool the Client constructor to avoid creating a new connection.
+    cloned_client = datastore.Client(project=client.project,
+                                     namespace=client.namespace,
+                                     http=object())
+    cloned_client.connection = client.connection
+    return cloned_client
+
+
 def setUpModule():
     if EMULATOR_DATASET is None:
-        client.DATASET = TESTS_DATASET
-        Config.CLIENT = datastore.Client()
+        client_mod.DATASET = TESTS_DATASET
+        Config.CLIENT = datastore.Client(namespace=TEST_NAMESPACE)
     else:
-        Config.CLIENT = datastore.Client(project=EMULATOR_DATASET)
-        populate_datastore.add_characters(client=Config.CLIENT)
-
-
-def tearDownModule():
-    if EMULATOR_DATASET is not None:
-        clear_datastore.remove_all_entities(client=Config.CLIENT)
+        Config.CLIENT = datastore.Client(project=EMULATOR_DATASET,
+                                         namespace=TEST_NAMESPACE)
 
 
 class TestDatastore(unittest2.TestCase):
@@ -87,7 +94,6 @@ class TestDatastoreSave(TestDatastore):
 
     @classmethod
     def setUpClass(cls):
-        super(TestDatastoreSave, cls).setUpClass()
         cls.PARENT = Config.CLIENT.key('Blog', 'PizzaMan')
 
     def _get_post(self, id_or_name=None, post_content=None):
@@ -194,13 +200,32 @@ class TestDatastoreQuery(TestDatastore):
 
     @classmethod
     def setUpClass(cls):
-        super(TestDatastoreQuery, cls).setUpClass()
+        cls.CLIENT = clone_client(Config.CLIENT)
+        # Remove the namespace from the cloned client, since these
+        # query tests rely on the entities to be already stored and indexed,
+        # hence ``TEST_NAMESPACE`` set at runtime can't be used.
+        cls.CLIENT.namespace = None
+
+        # In the emulator, re-populating the datastore is cheap.
+        if EMULATOR_DATASET is not None:
+            # Populate the datastore with the cloned client.
+            populate_datastore.add_characters(client=cls.CLIENT)
+
         cls.CHARACTERS = populate_datastore.CHARACTERS
-        cls.ANCESTOR_KEY = Config.CLIENT.key(*populate_datastore.ANCESTOR)
+        # Use the client for this test instead of the global.
+        cls.ANCESTOR_KEY = cls.CLIENT.key(*populate_datastore.ANCESTOR)
+
+    @classmethod
+    def tearDownClass(cls):
+        # In the emulator, destroy the query entities.
+        if EMULATOR_DATASET is not None:
+            # Use the client for this test instead of the global.
+            clear_datastore.remove_all_entities(client=cls.CLIENT)
 
     def _base_query(self):
-        return Config.CLIENT.query(kind='Character',
-                                   ancestor=self.ANCESTOR_KEY)
+        # Use the client for this test instead of the global.
+        return self.CLIENT.query(kind='Character',
+                                 ancestor=self.ANCESTOR_KEY)
 
     def test_limit_queries(self):
         limit = 5
@@ -245,7 +270,8 @@ def test_ancestor_query(self):
         self.assertEqual(len(entities), expected_matches)
 
     def test_query___key___filter(self):
-        rickard_key = Config.CLIENT.key(*populate_datastore.RICKARD)
+        # Use the client for this test instead of the global.
+        rickard_key = self.CLIENT.key(*populate_datastore.RICKARD)
 
         query = self._base_query()
         query.add_filter('__key__', '=', rickard_key)
@@ -377,11 +403,8 @@ def test_transaction(self):
         self.assertEqual(retrieved_entity, entity)
 
     def test_failure_with_contention(self):
-        contention_key = 'baz'
-        # Fool the Client constructor to avoid creating a new connection.
-        local_client = datastore.Client(project=Config.CLIENT.project,
-                                        http=object())
-        local_client.connection = Config.CLIENT.connection
+        contention_prop_name = 'baz'
+        local_client = clone_client(Config.CLIENT)
 
         # Insert an entity which will be retrieved in a transaction
         # and updated outside it with a contentious value.
@@ -396,10 +419,10 @@ def test_failure_with_contention(self):
                 entity_in_txn = local_client.get(key)
 
                 # Update the original entity outside the transaction.
-                orig_entity[contention_key] = u'outside'
+                orig_entity[contention_prop_name] = u'outside'
                 Config.CLIENT.put(orig_entity)
 
                 # Try to update the entity which we already updated outside the
                 # transaction.
-                entity_in_txn[contention_key] = u'inside'
+                entity_in_txn[contention_prop_name] = u'inside'
                 txn.put(entity_in_txn)