crowdus · crowdus · Aug 23, 2019 · Aug 8, 2019 · Aug 9, 2019 · Aug 12, 2019
diff --git a/appengine/flexible/tasks/snippets.py b/appengine/flexible/tasks/snippets.py
@@ -176,41 +176,59 @@ def create_task_with_name(project, location, queue, task_name):
 
 
 def delete_task(project, location, queue):
-    # [START taskqueues_setup]
+    # [START taskqueues_deleting_tasks]
     client = tasks.CloudTasksClient()
 
     # TODO(developer): Uncomment these lines and replace with your values.
     # project = 'my-project-id'
     # location = 'us- central1'
     # queue = 'queue1'
-    # [START taskqueues_setup]
 
-    # [START taskqueues_deleting_tasks]
     task_path = client.task_path(project, location, queue, 'foo')
     response = client.delete_task(task_path)
     # [END taskqueues_deleting_tasks]
+    return response
 
+
+def purge_queue(project, location, queue):
     # [START taskqueues_purging_tasks]
+    client = tasks.CloudTasksClient()
+
+    # TODO(developer): Uncomment these lines and replace with your values.
+    # project = 'my-project-id'
+    # location = 'us- central1'
+    # queue = 'queue1'
+
     queue_path = client.queue_path(project, location, queue)
     response = client.purge_queue(queue_path)
     # [END taskqueues_purging_tasks]
+    return response
+
 
+def pause_queue(project, location, queue):
     # [START taskqueues_pause_queue]
+    client = tasks.CloudTasksClient()
+
+    # TODO(developer): Uncomment these lines and replace with your values.
+    # project = 'my-project-id'
+    # location = 'us- central1'
+    # queue = 'queue1'
+
     queue_path = client.queue_path(project, location, queue)
     response = client.pause_queue(queue_path)
     # [END taskqueues_pause_queues]
     return response
 
 
 def delete_queue(project, location, queue):
+    # [START taskqueues_deleting_queues]
     client = tasks.CloudTasksClient()
 
     # TODO(developer): Uncomment these lines and replace with your values.
     # project = 'my-project-id'
     # location = 'us- central1'
     # queue = 'queue1'
 
-    # [START taskqueues_deleting_queues]
     queue_path = client.queue_path(project, location, queue)
     response = client.delete_queue(queue_path)
     # [END taskqueues_deleting_queues]

diff --git a/appengine/flexible/tasks/snippets_test.py b/appengine/flexible/tasks/snippets_test.py
@@ -71,14 +71,30 @@ def test_create_task_with_name():
 
 @pytest.mark.order6
 def test_delete_task():
+    result = snippets.delete_task(
+        TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
+    assert result is None
+
+
+@pytest.mark.order7
+def test_purge_queue():
     name = "projects/{}/locations/{}/queues/{}".format(
         TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
-    result = snippets.delete_task(
+    result = snippets.purge_queue(
         TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
     assert name in result.name
 
 
-@pytest.mark.order7
+@pytest.mark.order8
+def test_pause_queue():
+    name = "projects/{}/locations/{}/queues/{}".format(
+        TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
+    result = snippets.pause_queue(
+        TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
+    assert name in result.name
+
+
+@pytest.mark.order9
 def test_delete_queue():
     result = snippets.delete_queue(
         TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
@@ -89,7 +105,7 @@ def test_delete_queue():
     assert result is None
 
 
-@pytest.mark.order8
+@pytest.mark.order10
 def test_retry_task():
     QUEUE_SIZE = 3
     QUEUE_NAME = []

diff --git a/appengine/standard/i18n/i18n_utils.py b/appengine/standard/i18n/i18n_utils.py
@@ -19,7 +19,7 @@
 The idea of this example, especially for how to translate strings in
 Javascript is originally from an implementation of Django i18n.
 """
-
+from __future__ import print_function
 
 import gettext
 import json
@@ -31,6 +31,11 @@
 
 from webob import Request
 
+try:
+    basestring
+except NameError:
+    basestring = str
+
 
 def _get_plural_forms(js_translations):
     """Extracts the parameters for what constitutes a plural.
@@ -49,15 +54,15 @@ def _get_plural_forms(js_translations):
         for l in js_translations._catalog[''].split('\n'):
             if l.startswith('Plural-Forms:'):
                 plural = l.split(':', 1)[1].strip()
-                print "plural is %s" % plural
+                print('plural is {}'.format(plural))
     if plural is not None:
         for raw_element in plural.split(';'):
             element = raw_element.strip()
             if element.startswith('nplurals='):
                 n_plural = int(element.split('=', 1)[1])
             elif element.startswith('plural='):
                 plural = element.split('=', 1)[1]
-                print "plural is now %s" % plural
+                print('plural is now {}'.format(plural))
     else:
         n_plural = 2
         plural = '(n == 1) ? 0 : 1'
@@ -83,9 +88,9 @@ def convert_translations_to_dict(js_translations):
     for key, value in js_translations._catalog.items():
         if key == '':
             continue
-        if type(key) in (str, unicode):
+        if isinstance(key, basestring):
             translations_dict['catalog'][key] = value
-        elif type(key) == tuple:
+        elif isinstance(key, tuple):
             if key[0] not in translations_dict['catalog']:
                 translations_dict['catalog'][key[0]] = [''] * n_plural
             translations_dict['catalog'][key[0]][int(key[1])] = value

diff --git a/appengine/standard/mail/header.py b/appengine/standard/mail/header.py
@@ -1,3 +1,4 @@
+from __future__ import print_function
 # Copyright 2016 Google Inc. All rights reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
@@ -40,7 +41,7 @@ def get(self):
         </form></body></html>""")
 
     def post(self):
-        print repr(self.request.POST)
+        print(repr(self.request.POST))
         id = self.request.POST['thread_id']
         send_example_mail('{}@appspot.gserviceaccount.com'.format(
             app_identity.get_application_id()), id)

diff --git a/appengine/standard/ndb/properties/snippets.py b/appengine/standard/ndb/properties/snippets.py
@@ -1,3 +1,4 @@
+from __future__ import print_function
 # Copyright 2016 Google Inc. All rights reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
@@ -147,4 +148,4 @@ class Part(ndb.Model):
 
 def print_part():
     p1 = Part(name='foo', color=Color.RED)
-    print p1.color  # prints "RED"
+    print(p1.color)  # prints "RED"
diff --git a/appengine/standard/ndb/queries/snippets_test.py b/appengine/standard/ndb/queries/snippets_test.py
@@ -1,3 +1,4 @@
+from __future__ import print_function
 # Copyright 2016 Google Inc. All rights reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
@@ -343,7 +344,7 @@ def test_fetch_message_accounts_inefficient(testbed):
 
     assert len(message_account_pairs) == 5
 
-    print repr(message_account_pairs)
+    print(repr(message_account_pairs))
     for i in range(1, 6):
         message, account = message_account_pairs[i - 1]
         assert message.content == 'Message %s' % i

diff --git a/appengine/standard_python37/django/requirements.txt b/appengine/standard_python37/django/requirements.txt
@@ -1,2 +1,2 @@
-Django==2.1.10
+Django==2.1.11
 PyMySQL==0.9.3
diff --git a/asset/cloud-client/quickstart_createfeed.py b/asset/cloud-client/quickstart_createfeed.py
@@ -0,0 +1,51 @@
+#!/usr/bin/env python
+
+# Copyright 2019 Google LLC.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+
+import argparse
+
+
+def create_feed(project_id, feed_id, asset_names, topic):
+    # [START asset_quickstart_create_feed]
+    from google.cloud import asset_v1p2beta1
+    from google.cloud.asset_v1p2beta1.proto import asset_service_pb2
+
+    # TODO project_id = 'Your Google Cloud Project ID'
+    # TODO feed_id = 'Feed ID you want to create'
+    # TODO asset_names = 'List of asset names the feed listen to'
+    # TODO topic = "Topic name of the feed"
+
+    client = asset_v1p2beta1.AssetServiceClient()
+    parent = "projects/{}".format(project_id)
+    feed = asset_service_pb2.Feed()
+    feed.asset_names.extend(asset_names)
+    feed.feed_output_config.pubsub_destination.topic = topic
+    response = client.create_feed(parent, feed_id, feed)
+    print('feed: {}'.format(response))
+    # [END asset_quickstart_create_feed]
+
+
+if __name__ == '__main__':
+    parser = argparse.ArgumentParser(
+        description=__doc__,
+        formatter_class=argparse.RawDescriptionHelpFormatter)
+    parser.add_argument('project_id', help='Your Google Cloud project ID')
+    parser.add_argument('feed_id', help='Feed ID you want to create')
+    parser.add_argument('asset_names',
+                        help='List of asset names the feed listen to')
+    parser.add_argument('topic', help='Topic name of the feed')
+    args = parser.parse_args()
+    create_feed(args.project_id, args.feed_id, args.asset_names, args.topic)
diff --git a/asset/cloud-client/quickstart_createfeed_test.py b/asset/cloud-client/quickstart_createfeed_test.py
@@ -0,0 +1,44 @@
+#!/usr/bin/env python
+
+# Copyright 2018 Google LLC.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import json
+import os
+import time
+
+import quickstart_createfeed
+import quickstart_deletefeed
+from google.cloud import resource_manager
+
+json_data = open(os.environ["GOOGLE_APPLICATION_CREDENTIALS"]).read()
+data = json.loads(json_data)
+PROJECT = data['project_id']
+ASSET_NAME = 'assets-{}'.format(int(time.time()))
+FEED_ID = 'feed-{}'.format(int(time.time()))
+TOPIC = 'topic-{}'.format(int(time.time()))
+
+
+def test_create_feed(capsys):
+    client = resource_manager.Client()
+    project_number = client.fetch_project(PROJECT).number
+    full_topic_name = "projects/{}/topics/{}".format(PROJECT, TOPIC)
+    quickstart_createfeed.create_feed(
+        PROJECT, FEED_ID, [ASSET_NAME, ], full_topic_name)
+    out, _ = capsys.readouterr()
+    assert "feed" in out
+
+    # Clean up, delete the feed
+    feed_name = "projects/{}/feeds/{}".format(project_number, FEED_ID)
+    quickstart_deletefeed.delete_feed(feed_name)
diff --git a/asset/cloud-client/quickstart_deletefeed.py b/asset/cloud-client/quickstart_deletefeed.py
@@ -0,0 +1,39 @@
+#!/usr/bin/env python
+
+# Copyright 2018 Google LLC.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+
+import argparse
+
+
+def delete_feed(feed_name):
+    # [START asset_quickstart_delete_feed]
+    from google.cloud import asset_v1p2beta1
+
+    # TODO feed_name = 'Feed name you want to delete'
+
+    client = asset_v1p2beta1.AssetServiceClient()
+    client.delete_feed(feed_name)
+    print('deleted_feed')
+    # [END asset_quickstart_delete_feed]
+
+
+if __name__ == '__main__':
+    parser = argparse.ArgumentParser(
+        description=__doc__,
+        formatter_class=argparse.RawDescriptionHelpFormatter)
+    parser.add_argument('feed_name', help='Feed name you want to delete')
+    args = parser.parse_args()
+    delete_feed(args.feed_name)
diff --git a/asset/cloud-client/quickstart_deletefeed_test.py b/asset/cloud-client/quickstart_deletefeed_test.py
@@ -0,0 +1,42 @@
+#!/usr/bin/env python
+
+# Copyright 2018 Google LLC.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import os
+import time
+
+import quickstart_createfeed
+import quickstart_deletefeed
+from google.cloud import resource_manager
+
+PROJECT = os.environ['GCLOUD_PROJECT']
+ASSET_NAME = 'assets-{}'.format(int(time.time()))
+FEED_ID = 'feed-{}'.format(int(time.time()))
+TOPIC = 'topic-{}'.format(int(time.time()))
+
+
+def test_delete_feed(capsys):
+    client = resource_manager.Client()
+    project_number = client.fetch_project(PROJECT).number
+    # First create the feed, which will be deleted later
+    full_topic_name = "projects/{}/topics/{}".format(PROJECT, TOPIC)
+    quickstart_createfeed.create_feed(
+        PROJECT, FEED_ID, [ASSET_NAME, ], full_topic_name)
+
+    feed_name = "projects/{}/feeds/{}".format(project_number, FEED_ID)
+    quickstart_deletefeed.delete_feed(feed_name)
+
+    out, _ = capsys.readouterr()
+    assert "deleted_feed" in out