Merge pull request #388 from aperture-data/release-0.4.20

Release 0.4.20

Author: gsaluja9

aperturedb/ConnectorRest.py

@@ -119,21 +119,25 @@ def _query(self, query, blob_array = [], try_resume=True):
         response.status_code = 0
         while tries < self.config.retry_max_attempts:
             tries += 1
-            response = self.http_session.post(self.url,
-                                              headers = headers,
-                                              files   = files,
-                                              verify  = self.use_ssl)
-            if response.status_code == 200:
-                # Parse response:
-                json_response       = json.loads(response.text)
-                import base64
-                response_blob_array = [base64.b64decode(
-                    b) for b in json_response['blobs']]
-                self.last_response  = json_response["json"]
-                break
-            logger.error(
-                f"Response not OK = {response.status_code} {response.text[:1000]}\n\
-                    attempt [{tries}/3] .. PID = {os.getpid()}")
+            try:
+                response = self.http_session.post(self.url,
+                                                  headers = headers,
+                                                  files   = files,
+                                                  verify  = self.use_ssl)
+                if response.status_code == 200:
+                    # Parse response:
+                    json_response       = json.loads(response.text)
+                    import base64
+                    response_blob_array = [base64.b64decode(
+                        b) for b in json_response['blobs']]
+                    self.last_response  = json_response["json"]
+                    break
+                logger.error(
+                    f"Response not OK = {response.status_code} {response.text[:1000]}\n\
+                        attempt [{tries}/3] .. PID = {os.getpid()}")
+            except Exception as e:
+                logger.error(f"Exception during http.post = {e}\n\
+                        attempt [{tries}/3] .. PID = {os.getpid()}")
 
             time.sleep(self.config.retry_interval_seconds)
 

aperturedb/Entities.py

@@ -250,7 +250,9 @@ def get_blob(self, entity) -> Any:
                 "count": True
             }
         }
-        if self.spec.operations:
+        # An entities object is created with the response of the query
+        # or a spec. Check if the spec is not None, and if it has operations.
+        if self.spec and self.spec.operations:
             cmd_params["operations"] = self.spec.operations.operations_arr
         query = [
             QueryBuilder().find_command(self.db_object, params=cmd_params)

aperturedb/__init__.py

@@ -7,7 +7,7 @@
 
 logger = logging.getLogger(__name__)
 
-__version__ = "0.4.19"
+__version__ = "0.4.20"
 
 # set log level
 logger.setLevel(logging.DEBUG)