Simplify loop handling in async Consul client (#93)

- Align with aiohttp's BaseConnector pattern of using `loop = loop or asyncio.get_running_loop()`
- Remove redundant loop retrieval logic
- Use `asyncio.get_running_loop()` instead of deprecated `asyncio.get_event_loop()`
- Update documentation example to use `asyncio.get_running_loop()`

Author: cpaillet

CHANGELOG.md

@@ -1,5 +1,11 @@
 # Change log
 
+
+## 1.5.5
+
+- **fix:**  Simplify loop handling in async Consul client
+
+
 ## 1.5.4
 
 - **feature:**  Improve robustness of JSON decoding

consul/__init__.py

@@ -1,4 +1,4 @@
-__version__ = "1.5.4"
+__version__ = "1.5.5"
 
 from consul.check import Check
 from consul.exceptions import ACLDisabled, ACLPermissionDenied, ConsulException, NotFound, Timeout

consul/aio.py

@@ -1,4 +1,3 @@
-import asyncio
 from typing import Dict, Optional
 
 import aiohttp
@@ -13,11 +12,11 @@ class HTTPClient(base.HTTPClient):
 
     def __init__(self, *args, loop=None, connections_limit=None, connections_timeout=None, **kwargs) -> None:
         super().__init__(*args, **kwargs)
-        self._loop = loop or asyncio.get_event_loop()
+        self.loop = loop
         connector_kwargs = {}
         if connections_limit:
             connector_kwargs["limit"] = connections_limit
-        connector = aiohttp.TCPConnector(loop=self._loop, verify_ssl=self.verify, **connector_kwargs)
+        connector = aiohttp.TCPConnector(loop=self.loop, verify_ssl=self.verify, **connector_kwargs)
         session_kwargs = {}
         if connections_timeout:
             timeout = aiohttp.ClientTimeout(total=connections_timeout)
@@ -76,7 +75,7 @@ def close(self):
 
 class Consul(base.Consul):
     def __init__(self, *args, loop=None, connections_limit=None, connections_timeout=None, **kwargs) -> None:
-        self._loop = loop or asyncio.get_event_loop()
+        self.loop = loop
         self.connections_limit = connections_limit
         self.connections_timeout = connections_timeout
         super().__init__(*args, **kwargs)
@@ -86,7 +85,7 @@ def http_connect(self, host: str, port: int, scheme, verify: bool = True, cert=N
             host,
             port,
             scheme,
-            loop=self._loop,
+            loop=self.loop,
             connections_limit=self.connections_limit,
             connections_timeout=self.connections_timeout,
             verify=verify,

docs/index.rst

@@ -58,7 +58,7 @@ result of each API call. This client is available in *consul.aio*.
     import consul.aio
 
 
-    loop = asyncio.get_event_loop()
+    loop = asyncio.get_running_loop()
 
     @asyncio.coroutine
     def go():