Merge pull request #10 from 4poc/fix_missing_accessKey
Add missing accessKey param to get/delete_event
diff --git a/predictionio/__init__.py b/predictionio/__init__.py
index ecb6f27..2a09995 100644
--- a/predictionio/__init__.py
+++ b/predictionio/__init__.py
@@ -228,7 +228,7 @@
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 @@
"""
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 @@
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
