Merge pull request #8 from dataiku/release/1.0.2

Release/1.0.2

Author: alexbourret

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## [Version 1.0.2](https://github.com/dataiku/dss-plugin-api-connect/releases/tag/v1.0.2) - Bugfix release - 2021-05-25
+
+- Fixed recipe ignoring the selected http_method
+
 ## [Version 1.0.1](https://github.com/dataiku/dss-plugin-api-connect/releases/tag/v1.0.1) - Bugfix release - 2021-05-03
 
 - Fixed the "Per page" pagination mode

plugin.json

@@ -1,6 +1,6 @@
 {
     "id": "api-connect",
-    "version": "1.0.1",
+    "version": "1.0.2",
     "meta": {
         "label": "API Connect",
         "description": "Retrieve data from any REST API",

python-lib/rest_api_client.py

@@ -160,16 +160,11 @@ def request(self, method, url, can_raise_exeption=True, **kwargs):
         self.pagination.update_next_page(json_response)
         return json_response
 
-    def paginated_get(self, can_raise_exeption=True):
+    def paginated_api_call(self, can_raise_exeption=True):
         pagination_params = self.pagination.get_params()
         params = self.requests_kwargs.get("params")
         params.update(pagination_params)
         self.requests_kwargs.update({"params": params})
-        return self.get(self.pagination.get_next_page_url(), can_raise_exeption, **self.requests_kwargs)
-
-    def paginated_api_call(self, can_raise_exeption=True):
-        if self.http_method == "GET":
-            return self.paginated_get(can_raise_exeption=True)
         return self.request(self.http_method, self.pagination.get_next_page_url(), can_raise_exeption, **self.requests_kwargs)
 
     @staticmethod

python-lib/rest_api_recipe_session.py

@@ -53,7 +53,7 @@ def retrieve_next_page(self, is_raw_output):
         page_rows = []
         base_row = copy.deepcopy(self.initial_parameter_columns)
         logger.info("retrieve_next_page: Calling next page")
-        json_response = self.client.paginated_get(can_raise_exeption=False)
+        json_response = self.client.paginated_api_call(can_raise_exeption=False)
         if self.extraction_key:
             data_rows = json_response.get(self.extraction_key, [json_response])
             if data_rows is None: