Merge pull request #61 from oslokommune/DP-1690-add-event-poster-retries

DP-1690 Add retry option to event poster

Author: simenheg

CHANGELOG.md

@@ -1,3 +1,7 @@
+## ?.?.?
+
+* `PostEvent.post_event` now also supports retries.
+
 ## 0.6.0
 
 * Added `Dataset.get_distribution` method.

okdata/sdk/event/post_event.py

@@ -11,7 +11,7 @@ def __init__(self, config=None, auth=None, env=None):
         super().__init__(config, auth, env)
         self.event_collector_url = self.config.get("eventCollectorUrl")
 
-    def post_event(self, event_payload, dataset_id, version_id):
+    def post_event(self, event_payload, dataset_id, version_id, retries=0):
 
         if type(event_payload) is dict:
             post_url = f"{self.event_collector_url}/event/{dataset_id}/{version_id}"
@@ -22,4 +22,4 @@ def post_event(self, event_payload, dataset_id, version_id):
                 f"Invalid type: {type(event_payload)}. Must be either {list} or {dict}"
             )
 
-        return self.post(post_url, event_payload).json()
+        return self.post(post_url, event_payload, retries=retries).json()