refactor(lint): address link issues

Author: parfeon

pubnub/request_handlers/async_httpx.py

@@ -137,10 +137,11 @@ async def async_request(self, options_func, cancellation_event):
             'headers': request_headers,
             'url': full_url,
             'follow_redirects': options.allow_redirects,
-            'timeout': httpx.Timeout(connect=options.connect_timeout,
-                                    read=options.request_timeout,
-                                    write=options.connect_timeout,
-                                    pool=options.connect_timeout),
+            'timeout': httpx.Timeout(
+                connect=options.connect_timeout,
+                read=options.request_timeout,
+                write=options.connect_timeout,
+                pool=options.connect_timeout),
         }
         if options.is_post() or options.is_patch():
             request_arguments['content'] = options.data

pubnub/request_handlers/httpx.py

@@ -346,10 +346,11 @@ def _invoke_request(self, p_options, e_options, base_origin):
             "method": e_options.method_string,
             "headers": request_headers,
             "url": httpx.URL(url, query=e_options.query_string.encode("utf-8")),
-            "timeout": httpx.Timeout(connect=e_options.connect_timeout,
-                                    read=e_options.request_timeout,
-                                    write=e_options.connect_timeout,
-                                    pool=e_options.connect_timeout),
+            "timeout": httpx.Timeout(
+                connect=e_options.connect_timeout,
+                read=e_options.request_timeout,
+                write=e_options.connect_timeout,
+                pool=e_options.connect_timeout),
             "follow_redirects": e_options.allow_redirects
         }
 

tests/integrational/native_threads/test_subscribe.py

@@ -182,7 +182,9 @@ def test_cg_subscribe_unsubscribe(self):
             if result is None:
                 self.fail("Remove channel from channel group operation timeout or failed")
             if cg_remove_operation.status is not None and cg_remove_operation.status.is_error():
-                self.fail(f"Remove channel from channel group operation failed with error: {cg_remove_operation.status}")
+                self.fail(
+                    f"Remove channel from channel group failed: {cg_remove_operation.status}"
+                )
             assert isinstance(result, PNChannelGroupsRemoveChannelResult)
         finally:
             pubnub.stop()
@@ -239,7 +241,9 @@ def test_subscribe_cg_publish_unsubscribe(self):
             if result is None:
                 self.fail("Remove channel from channel group operation timeout or failed")
             if non_subscribe_listener.status is not None and non_subscribe_listener.status.is_error():
-                self.fail(f"Remove channel from channel group operation failed with error: {non_subscribe_listener.status}")
+                self.fail(
+                    f"Remove channel from channel group failed: {non_subscribe_listener.status}"
+                )
             assert isinstance(result, PNChannelGroupsRemoveChannelResult)
         finally:
             pubnub.stop()

tests/unit/test_wall_clock_deadline.py

@@ -360,7 +360,6 @@ class TestHttpxRequestHandlerCleanup(unittest.TestCase):
     def test_close_stops_watchdog(self):
         """HttpxRequestHandler.close() should stop the watchdog thread."""
         from pubnub.request_handlers.httpx import HttpxRequestHandler
-        from tests.helper import pnconf_copy
 
         handler = HttpxRequestHandler(MagicMock())
         # Start the watchdog by setting a deadline