Merge pull request apache#10 from 4poc/fix_missing_accessKey

Justin Yip · Justin Yip · commit ffa04e5ec40d · 2014-12-09T02:14:31.000-08:00
Add missing accessKey param to get/delete_event
diff --git a/predictionio/__init__.py b/predictionio/__init__.py
@@ -228,7 +228,7 @@ def acreate_event(self, event, entity_type, entity_id,
     et_str = et.strftime("%Y-%m-%dT%H:%M:%S.%f")[:-3] + et.strftime("%z")
     data["eventTime"] = et_str
     
-    path = "/events.json?accessKey=" + self.access_key
+    path = "/events.json?accessKey=%s" % (self.access_key, )
     request = AsyncRequest("POST", path, **data)
     request.set_rfunc(self._acreate_resp)
     self._connection.make_request(request)
@@ -253,7 +253,7 @@ def aget_event(self, event_id):
     """
     enc_event_id = urllib.quote(event_id, "") # replace special char with %xx
     path = "/events/%s.json" % enc_event_id
-    request = AsyncRequest("GET", path)
+    request = AsyncRequest("GET", path, accessKey=self.access_key)
     request.set_rfunc(self._aget_resp)
     self._connection.make_request(request)
     return request
@@ -272,8 +272,8 @@ def adelete_event(self, event_id):
       AsyncRequest object. 
     """
     enc_event_id = urllib.quote(event_id, "") # replace special char with %xx
-    path = "/events/%s.json" % enc_event_id
-    request = AsyncRequest("DELETE", path)
+    path = "/events/%s.json" % (enc_event_id, )
+    request = AsyncRequest("DELETE", path, accessKey=self.access_key)
     request.set_rfunc(self._adelete_resp)
     self._connection.make_request(request)
     return request
