Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings

Commit c7fdb13

Browse filesBrowse files
authored
Split Cloud Tasks snippet methods (GoogleCloudPlatform#2332)
1 parent 1db16b8 commit c7fdb13
Copy full SHA for c7fdb13

File tree

Expand file treeCollapse file tree

2 files changed

+40
-6
lines changed
Filter options
Expand file treeCollapse file tree

2 files changed

+40
-6
lines changed

‎appengine/flexible/tasks/snippets.py

Copy file name to clipboardExpand all lines: appengine/flexible/tasks/snippets.py
+21-3Lines changed: 21 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -176,26 +176,44 @@ def create_task_with_name(project, location, queue, task_name):
176176

177177

178178
def delete_task(project, location, queue):
179-
# [START taskqueues_setup]
179+
# [START taskqueues_deleting_tasks]
180180
client = tasks.CloudTasksClient()
181181

182182
# TODO(developer): Uncomment these lines and replace with your values.
183183
# project = 'my-project-id'
184184
# location = 'us- central1'
185185
# queue = 'queue1'
186-
# [END taskqueues_setup]
187186

188-
# [START taskqueues_deleting_tasks]
189187
task_path = client.task_path(project, location, queue, 'foo')
190188
response = client.delete_task(task_path)
191189
# [END taskqueues_deleting_tasks]
190+
return response
192191

192+
193+
def purge_queue(project, location, queue):
193194
# [START taskqueues_purging_tasks]
195+
client = tasks.CloudTasksClient()
196+
197+
# TODO(developer): Uncomment these lines and replace with your values.
198+
# project = 'my-project-id'
199+
# location = 'us- central1'
200+
# queue = 'queue1'
201+
194202
queue_path = client.queue_path(project, location, queue)
195203
response = client.purge_queue(queue_path)
196204
# [END taskqueues_purging_tasks]
205+
return response
206+
197207

208+
def pause_queue(project, location, queue):
198209
# [START taskqueues_pause_queue]
210+
client = tasks.CloudTasksClient()
211+
212+
# TODO(developer): Uncomment these lines and replace with your values.
213+
# project = 'my-project-id'
214+
# location = 'us- central1'
215+
# queue = 'queue1'
216+
199217
queue_path = client.queue_path(project, location, queue)
200218
response = client.pause_queue(queue_path)
201219
# [END taskqueues_pause_queues]

‎appengine/flexible/tasks/snippets_test.py

Copy file name to clipboardExpand all lines: appengine/flexible/tasks/snippets_test.py
+19-3Lines changed: 19 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -71,14 +71,30 @@ def test_create_task_with_name():
7171

7272
@pytest.mark.order6
7373
def test_delete_task():
74+
result = snippets.delete_task(
75+
TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
76+
assert result is None
77+
78+
79+
@pytest.mark.order7
80+
def test_purge_queue():
7481
name = "projects/{}/locations/{}/queues/{}".format(
7582
TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
76-
result = snippets.delete_task(
83+
result = snippets.purge_queue(
7784
TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
7885
assert name in result.name
7986

8087

81-
@pytest.mark.order7
88+
@pytest.mark.order8
89+
def test_pause_queue():
90+
name = "projects/{}/locations/{}/queues/{}".format(
91+
TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
92+
result = snippets.pause_queue(
93+
TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
94+
assert name in result.name
95+
96+
97+
@pytest.mark.order9
8298
def test_delete_queue():
8399
result = snippets.delete_queue(
84100
TEST_PROJECT_ID, TEST_LOCATION, QUEUE_NAME_1)
@@ -89,7 +105,7 @@ def test_delete_queue():
89105
assert result is None
90106

91107

92-
@pytest.mark.order8
108+
@pytest.mark.order10
93109
def test_retry_task():
94110
QUEUE_SIZE = 3
95111
QUEUE_NAME = []

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.