Merge pull request #996 from dhermes/upgrade-pubsub-version

Upgrading pubsub to v1.

Author: dhermes

gcloud/pubsub/connection.py

@@ -28,7 +28,7 @@ class Connection(base_connection.JSONConnection):
     API_BASE_URL = 'https://pubsub.googleapis.com'
     """The base of the API call URL."""
 
-    API_VERSION = 'v1beta2'
+    API_VERSION = 'v1'
     """The version of the API, used in building the API call's URL."""
 
     API_URL_TEMPLATE = '{api_base_url}/{api_version}{path}'

gcloud/pubsub/subscription.py

@@ -246,7 +246,7 @@ def modify_ack_deadline(self, ack_id, ack_deadline, client=None):
                        ``client`` stored on the current subscription's topic.
         """
         client = self._require_client(client)
-        data = {'ackId': ack_id, 'ackDeadlineSeconds': ack_deadline}
+        data = {'ackIds': [ack_id], 'ackDeadlineSeconds': ack_deadline}
         client.connection.api_request(
             method='POST', path='%s:modifyAckDeadline' % (self.path,),
             data=data)

gcloud/pubsub/test_subscription.py

@@ -427,7 +427,7 @@ def test_modify_ack_deadline_w_bound_client(self):
         self.assertEqual(req['method'], 'POST')
         self.assertEqual(req['path'], '/%s:modifyAckDeadline' % SUB_PATH)
         self.assertEqual(req['data'],
-                         {'ackId': ACK_ID, 'ackDeadlineSeconds': DEADLINE})
+                         {'ackIds': [ACK_ID], 'ackDeadlineSeconds': DEADLINE})
 
     def test_modify_ack_deadline_w_alternate_client(self):
         PROJECT = 'PROJECT'
@@ -449,7 +449,7 @@ def test_modify_ack_deadline_w_alternate_client(self):
         self.assertEqual(req['method'], 'POST')
         self.assertEqual(req['path'], '/%s:modifyAckDeadline' % SUB_PATH)
         self.assertEqual(req['data'],
-                         {'ackId': ACK_ID, 'ackDeadlineSeconds': DEADLINE})
+                         {'ackIds': [ACK_ID], 'ackDeadlineSeconds': DEADLINE})
 
     def test_delete_w_bound_client(self):
         PROJECT = 'PROJECT'