Fix some warnings

Author: HardNorth

reportportal_client/aio/client.py

@@ -187,7 +187,7 @@ async def session(self) -> RetryingClientSession:
             else:
                 ssl_config = ssl.create_default_context(ssl.Purpose.SERVER_AUTH, cafile=certifi.where())
 
-        connection_params = {"ssl": ssl_config, "limit": self.max_pool_size}
+        connection_params: Dict[str, Any] = {"ssl": ssl_config, "limit": self.max_pool_size}
         if self.keepalive_timeout:
             connection_params["keepalive_timeout"] = self.keepalive_timeout
         connector = aiohttp.TCPConnector(**connection_params)
@@ -196,7 +196,7 @@ async def session(self) -> RetryingClientSession:
         if self.api_key:
             headers["Authorization"] = f"Bearer {self.api_key}"
 
-        session_params = {"headers": headers, "connector": connector}
+        session_params: Dict[str, Any] = {"headers": headers, "connector": connector}
 
         if self.http_timeout:
             if type(self.http_timeout) is tuple:
@@ -565,14 +565,14 @@ async def log_batch(self, log_batch: Optional[List[AsyncRPRequestLog]]) -> Optio
         :param log_batch: A list of log message objects.
         :return:          Completion message tuple of variable size (depending on request size).
         """
+        if not log_batch:
+            return None
+
         url = root_uri_join(self.base_url_v2, "log")
-        if log_batch:
-            response = await ErrorPrintingAsyncHttpRequest(
-                (await self.session()).post, url=url, data=AsyncRPLogBatch(log_batch).payload, name="log"
-            ).make()
-            if not response:
-                return None
-            return await response.messages
+        response = await ErrorPrintingAsyncHttpRequest(
+            (await self.session()).post, url=url, data=AsyncRPLogBatch(log_batch).payload, name="log"
+        ).make()
+        return await response.messages if response else None
 
     def clone(self) -> "Client":
         """Clone the client object, set current Item ID as cloned item ID.
@@ -1010,6 +1010,7 @@ async def close(self) -> None:
         await self.__client.close()
 
 
+# noinspection PyAbstractClass
 class _RPClient(RP, metaclass=AbstractBaseClass):
     """Base class for different synchronous to asynchronous client implementations."""
 
@@ -1454,7 +1455,7 @@ class ThreadedRPClient(_RPClient):
 
     task_timeout: float
     shutdown_timeout: float
-    _task_list: BackgroundTaskList[Task[_T]]
+    _task_list: BackgroundTaskList[Task[Any]]
     _task_mutex: threading.RLock
     _loop: Optional[asyncio.AbstractEventLoop]
     _thread: Optional[threading.Thread]
@@ -1645,7 +1646,7 @@ class BatchedRPClient(_RPClient):
     trigger_interval: float
     _loop: asyncio.AbstractEventLoop
     _task_mutex: threading.RLock
-    _task_list: TriggerTaskBatcher[Task[_T]]
+    _task_list: TriggerTaskBatcher[Task[Any]]
     __last_run_time: float
 
     def __init_task_list(

reportportal_client/client.py

@@ -66,12 +66,13 @@ class OutputType(aenum.Enum):
 
     def get_output(self) -> Optional[TextIO]:
         """Return TextIO based on the current type."""
-        if self == OutputType.STDOUT:
-            return sys.stdout
         if self == OutputType.STDERR:
             return sys.stderr
+        else:
+            return sys.stdout
 
 
+# noinspection PyAbstractClass
 class RP(metaclass=AbstractBaseClass):
     """Common interface for ReportPortal clients.
 
@@ -804,18 +805,19 @@ def update_test_item(
         return response.message
 
     def _log(self, batch: Optional[List[RPRequestLog]]) -> Optional[Tuple[str, ...]]:
-        if batch:
-            url = uri_join(self.base_url_v2, "log")
-            response = ErrorPrintingHttpRequest(
-                self.session.post,
-                url,
-                files=RPLogBatch(batch).payload,
-                verify_ssl=self.verify_ssl,
-                http_timeout=self.http_timeout,
-                name="log",
-            ).make()
-            if response:
-                return response.messages
+        if not batch:
+            return None
+
+        url = uri_join(self.base_url_v2, "log")
+        response = ErrorPrintingHttpRequest(
+            self.session.post,
+            url,
+            files=RPLogBatch(batch).payload,
+            verify_ssl=self.verify_ssl,
+            http_timeout=self.http_timeout,
+            name="log",
+        ).make()
+        return response.messages if response else None
 
     def log(
         self,