Fix review comments

Author: HardNorth

reportportal_client/_internal/aio/http.py

@@ -99,6 +99,9 @@ async def __request(self, method: Callable, url, **kwargs: Any) -> ClientRespons
 
         for i in range(self.__retry_number + 1):  # add one for the first attempt, which is not a retry
             retry_factor = None
+            if result is not None:
+                # Close previous result if it's retried to release resources
+                result.close()
             try:
                 result = await method(url, **kwargs)
             except Exception as exc:
@@ -207,6 +210,8 @@ async def __request(self, method: Callable, url: str, **kwargs: Any) -> ClientRe
         if result.status in AUTH_PROBLEM_STATUSES and self.__auth:
             refreshed_header = await self.__auth.refresh()
             if refreshed_header:
+                # Close previous result if it's retried to release resources
+                result.close()
                 # Retry with new auth header
                 request_kwargs["headers"] = request_kwargs.get("headers", {}).copy()
                 request_kwargs["headers"]["Authorization"] = refreshed_header

reportportal_client/_internal/services/statistics.py

@@ -95,6 +95,7 @@ def send_event(
         )
     except requests.exceptions.RequestException as err:
         logger.debug("Failed to send data to Statistics service: %s", str(err))
+        return None
 
 
 async def async_send_event(
@@ -121,7 +122,7 @@ async def async_send_event(
                 ssl=ssl_context,
             )
         except aiohttp.ClientError as exc:
-            logger.debug("Failed to send data to Statistics service: connection error", exc)
+            logger.debug("Failed to send data to Statistics service: %s", str(exc))
             return None
         if not result.ok:
             logger.debug(f"Failed to send data to Statistics service: {result.reason}")

tests/_internal/services/test_auth.py

@@ -14,6 +14,7 @@
 #  See the License for the specific language governing permissions and
 #  limitations under the License
 
+import asyncio
 import time
 from unittest import mock
 
@@ -326,7 +327,7 @@ async def test_happy_path_token_refresh(self):
         assert mock_session.post.call_count == 1
 
         # Wait for token to expire
-        time.sleep(1)
+        await asyncio.sleep(1)
 
         # Second call - token expired, should refresh
         new_access_token = "new_access_token"