Request patches (#8)

* Dependency update

* let requests properly encode params

* Break on too many errors

* flake edits

Author: datadavev

isamples_export_client/export_client.py

@@ -68,6 +68,7 @@ def __init__(self, query: str,
                  refresh_date: Optional[str] = None,
                  session: Session = requests.session(),
                  sleep_time: float = 5):
+        self._max_errors = 3  # Max number of errors in retrieval loop
         self._query = query
         self._destination_directory = destination_directory
         self._jwt = jwt
@@ -130,8 +131,9 @@ def create(self) -> str:
         if self._refresh_date is not None:
             query = self._query_with_timestamp()
 
-        create_url = f"{self._export_server_url}create?q={query}&export_format={self._format}"
-        response = self._rsession.get(create_url, headers=self._authentication_headers())
+        params = {"q": query, "export_format": self._format}
+        create_url = f"{self._export_server_url}create"
+        response = self._rsession.get(create_url, headers=self._authentication_headers(), params=params)
         if _is_expected_response_code(response):
             json = response.json()
             return json.get("uuid")
@@ -312,6 +314,7 @@ def perform_full_download(self):
         tstarted = datetime.datetime.now()
         uuid = self.create()
         logging.info(f"Contacted the export service, created export job with uuid {uuid}")
+        error_count = 0
         while True:
             try:
                 status_json = self.status(uuid)
@@ -344,3 +347,7 @@ def perform_full_download(self):
                 logging.error("An error occurred:", e)
                 # Sleep for a short time before retrying after an error
                 time.sleep(self._sleep_time)
+                error_count += 1
+            if error_count > self._max_errors:
+                logging.error("Maximum number of errors exceeded (%s/%s).", error_count, self._max_errors)
+                break