247giants
diff --git a/‎appengine/flexible/tasks/create_app_engine_queue_task.py
Copy file name to clipboardExpand all lines: appengine/flexible/tasks/create_app_engine_queue_task.py
+7-7Lines changed: 7 additions & 7 deletions b/‎appengine/flexible/tasks/create_app_engine_queue_task.py
Copy file name to clipboardExpand all lines: appengine/flexible/tasks/create_app_engine_queue_task.py
+7-7Lines changed: 7 additions & 7 deletions
diff --git a/‎appengine/flexible/tasks/main.py
Copy file name to clipboardExpand all lines: appengine/flexible/tasks/main.py
+2-2Lines changed: 2 additions & 2 deletions b/‎appengine/flexible/tasks/main.py
Copy file name to clipboardExpand all lines: appengine/flexible/tasks/main.py
+2-2Lines changed: 2 additions & 2 deletions
diff --git a/‎appengine/flexible/tasks/main_test.py
Copy file name to clipboardExpand all lines: appengine/flexible/tasks/main_test.py
+2-2Lines changed: 2 additions & 2 deletions b/‎appengine/flexible/tasks/main_test.py
Copy file name to clipboardExpand all lines: appengine/flexible/tasks/main_test.py
+2-2Lines changed: 2 additions & 2 deletions
diff --git a/‎tasks/pull_queue_snippets.py
Copy file name to clipboardExpand all lines: tasks/pull_queue_snippets.py
+2-2Lines changed: 2 additions & 2 deletions b/‎tasks/pull_queue_snippets.py
Copy file name to clipboardExpand all lines: tasks/pull_queue_snippets.py
+2-2Lines changed: 2 additions & 2 deletions
@@ -30,12 +30,12 @@ def create_task(project, queue, location, payload=None, in_seconds=None):
     client = googleapiclient.discovery.build('cloudtasks', 'v2beta2')
 
     # Construct the request body.
-    url = '/log_payload'
+    url = '/example_task_handler'
     body = {
         'task': {
-            'app_engine_http_request': {  # Specify the type of request.
-                'http_method': 'POST',
-                'relative_url': url
+            'appEngineHttpRequest': {  # Specify the type of request.
+                'httpMethod': 'POST',
+                'relativeUrl': url
             }
         }
     }
@@ -50,15 +50,15 @@ def create_task(project, queue, location, payload=None, in_seconds=None):
         converted_payload = base64_encoded_payload.decode()
 
         # Add the payload to the request.
-        body['task']['app_engine_http_request']['payload'] = converted_payload
+        body['task']['appEngineHttpRequest']['payload'] = converted_payload
 
     if in_seconds is not None:
         # Convert "seconds from now" into an rfc3339 datetime string.
         d = datetime.datetime.utcnow() + datetime.timedelta(seconds=in_seconds)
         scheduled_time = d.isoformat('T') + 'Z'
 
         # Add the rfc3339 datetime string to the request.
-        body['task']['schedule_time'] = scheduled_time
+        body['task']['scheduleTime'] = scheduled_time
 
     # Construct the fully qualified queue name.
     queue_name = 'projects/{}/locations/{}/queues/{}'.format(
@@ -104,7 +104,7 @@ def create_task(project, queue, location, payload=None, in_seconds=None):
     )
 
     parser.add_argument(
-        '--in_seconds',
+        '--in_seconds', type=int,
         help='The number of seconds from now to schedule task attempt.'
     )
 
 
@@ -20,8 +20,8 @@
 app = Flask(__name__)
 
 
-@app.route('/log_payload', methods=['POST'])
-def log_payload():
+@app.route('/example_task_handler', methods=['POST'])
+def example_task_handler():
     """Log the request payload."""
     payload = request.get_data(as_text=True) or '(empty payload)'
     print('Received task with payload: {}'.format(payload))
 
@@ -30,15 +30,15 @@ def test_index(app):
 def test_log_payload(capsys, app):
     payload = 'test_payload'
 
-    r = app.post('/log_payload', data=payload)
+    r = app.post('/example_task_handler', data=payload)
     assert r.status_code == 200
 
     out, _ = capsys.readouterr()
     assert payload in out
 
 
 def test_empty_payload(capsys, app):
-    r = app.post('/log_payload')
+    r = app.post('/example_task_handler')
     assert r.status_code == 200
 
     out, _ = capsys.readouterr()
 
@@ -47,7 +47,7 @@ def create_task(project, queue, location):
     # Construct the request body.
     task = {
         'task': {
-            'pull_message': {
+            'pullMessage': {
                 'payload': converted_payload
             }
         }
@@ -77,7 +77,7 @@ def pull_task(project, queue, location):
 
     duration_seconds = '600s'
     pull_options = {
-        'max_tasks': 1,
+        'maxTasks': 1,
         'leaseDuration': duration_seconds,
         'responseView': 'FULL'
     }
Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ def create_task(project, queue, location):`
`47`	`47`	`# Construct the request body.`
`48`	`48`	`task = {`
`49`	`49`	`'task': {`
`50`		`- 'pull_message': {`
	`50`	`+ 'pullMessage': {`
`51`	`51`	`'payload': converted_payload`
`52`	`52`	`}`
`53`	`53`	`}`
`@@ -77,7 +77,7 @@ def pull_task(project, queue, location):`
`77`	`77`
`78`	`78`	`duration_seconds = '600s'`
`79`	`79`	`pull_options = {`
`80`		`- 'max_tasks': 1,`
	`80`	`+ 'maxTasks': 1,`
`81`	`81`	`'leaseDuration': duration_seconds,`
`82`	`82`	`'responseView': 'FULL'`
`83`	`83`	`}`