style: apply black to metrics

python-microservices · Feb 13, 2021 · 4f2b7d3 · 4f2b7d3
1 parent 0f79218
commit 4f2b7d3
Showing 1 changed file with 32 additions and 16 deletions.
diff --git a/pyms/flask/services/requests.py b/pyms/flask/services/requests.py
@@ -163,7 +163,8 @@ def parse_response(self, response: Response) -> dict:
                 data = data.get(self.data, {})
             return data
         except ValueError:
-            logger.warning("Response.content is not a valid json {}".format(response.content))
+            logger.warning(
+                "Response.content is not a valid json {}".format(response.content))
             return {}
 
     @retry
@@ -190,12 +191,15 @@ def get(
         """
 
         full_url = self._build_url(url, path_params)
-        headers = self._get_headers(headers=headers, propagate_headers=propagate_headers)
+        headers = self._get_headers(
+            headers=headers, propagate_headers=propagate_headers)
         headers = self.insert_trace_headers(headers)
-        logger.debug("Get with url {}, params {}, headers {}, kwargs {}".format(full_url, params, headers, kwargs))
+        logger.debug("Get with url {}, params {}, headers {}, kwargs {}".format(
+            full_url, params, headers, kwargs))
 
         session = requests.Session()
-        response = self.requests(session=session).get(full_url, params=params, headers=headers, **kwargs)
+        response = self.requests(session=session).get(
+            full_url, params=params, headers=headers, **kwargs)
 
         return response
 
@@ -214,7 +218,8 @@ def get_for_object(
         :rtype: requests.Response
         """
 
-        response = self.get(url, path_params=path_params, params=params, headers=headers, **kwargs)
+        response = self.get(url, path_params=path_params,
+                            params=params, headers=headers, **kwargs)
         return self.parse_response(response)
 
     @retry
@@ -238,11 +243,13 @@ def post(
         headers = self._get_headers(headers)
         headers = self.insert_trace_headers(headers)
         logger.debug(
-            "Post with url {}, data {}, json {}, headers {}, kwargs {}".format(full_url, data, json, headers, kwargs)
+            "Post with url {}, data {}, json {}, headers {}, kwargs {}".format(
+                full_url, data, json, headers, kwargs)
         )
 
         session = requests.Session()
-        response = self.requests(session=session).post(full_url, data=data, json=json, headers=headers, **kwargs)
+        response = self.requests(session=session).post(
+            full_url, data=data, json=json, headers=headers, **kwargs)
         logger.debug("Response {}".format(response))
 
         return response
@@ -263,7 +270,8 @@ def post_for_object(
         :rtype: requests.Response
         """
 
-        response = self.post(url, path_params=path_params, data=data, json=json, headers=headers, **kwargs)
+        response = self.post(url, path_params=path_params,
+                             data=data, json=json, headers=headers, **kwargs)
         return self.parse_response(response)
 
     @retry
@@ -284,10 +292,12 @@ def put(self, url: str, path_params: dict = None, data: dict = None, headers: di
         full_url = self._build_url(url, path_params)
         headers = self._get_headers(headers)
         headers = self.insert_trace_headers(headers)
-        logger.debug("Put with url {}, data {}, headers {}, kwargs {}".format(full_url, data, headers, kwargs))
+        logger.debug("Put with url {}, data {}, headers {}, kwargs {}".format(
+            full_url, data, headers, kwargs))
 
         session = requests.Session()
-        response = self.requests(session=session).put(full_url, data, headers=headers, **kwargs)
+        response = self.requests(session=session).put(
+            full_url, data, headers=headers, **kwargs)
         logger.debug("Response {}".format(response))
 
         return response
@@ -308,7 +318,8 @@ def put_for_object(
         :rtype: requests.Response
         """
 
-        response = self.put(url, path_params=path_params, data=data, headers=headers, **kwargs)
+        response = self.put(url, path_params=path_params,
+                            data=data, headers=headers, **kwargs)
         return self.parse_response(response)
 
     @retry
@@ -329,10 +340,12 @@ def patch(self, url: str, path_params: dict = None, data: dict = None, headers:
         full_url = self._build_url(url, path_params)
         headers = self._get_headers(headers)
         headers = self.insert_trace_headers(headers)
-        logger.debug("Patch with url {}, data {}, headers {}, kwargs {}".format(full_url, data, headers, kwargs))
+        logger.debug("Patch with url {}, data {}, headers {}, kwargs {}".format(
+            full_url, data, headers, kwargs))
 
         session = requests.Session()
-        response = self.requests(session=session).patch(full_url, data, headers=headers, **kwargs)
+        response = self.requests(session=session).patch(
+            full_url, data, headers=headers, **kwargs)
         logger.debug("Response {}".format(response))
 
         return response
@@ -353,7 +366,8 @@ def patch_for_object(
         :rtype: requests.Response
         """
 
-        response = self.patch(url, path_params=path_params, data=data, headers=headers, **kwargs)
+        response = self.patch(url, path_params=path_params,
+                              data=data, headers=headers, **kwargs)
         return self.parse_response(response)
 
     @retry
@@ -371,10 +385,12 @@ def delete(self, url: str, path_params: dict = None, headers: dict = None, **kwa
         full_url = self._build_url(url, path_params)
         headers = self._get_headers(headers)
         headers = self.insert_trace_headers(headers)
-        logger.debug("Delete with url {}, headers {}, kwargs {}".format(full_url, headers, kwargs))
+        logger.debug("Delete with url {}, headers {}, kwargs {}".format(
+            full_url, headers, kwargs))
 
         session = requests.Session()
-        response = self.requests(session=session).delete(full_url, headers=headers, **kwargs)
+        response = self.requests(session=session).delete(
+            full_url, headers=headers, **kwargs)
         logger.debug("Response {}".format(response))
 
         return response