|
34 | 34 | import httpx |
35 | 35 | from bs4 import BeautifulSoup, PageElement, Tag |
36 | 36 | from docopt import docopt |
37 | | -from tenacity import retry, stop_after_attempt, wait_exponential |
| 37 | +from tenacity import retry, stop_after_attempt, wait_fixed |
38 | 38 |
|
39 | 39 | from recuair_cli import __version__ |
40 | 40 |
|
@@ -89,7 +89,7 @@ def _int_or_none(value: str) -> Optional[int]: |
89 | 89 | async def get_status(client: httpx.AsyncClient, device: str) -> Status: |
90 | 90 | """Return device status.""" |
91 | 91 | try: |
92 | | - response = await client.get(f"http://{device}/", timeout=3) |
| 92 | + response = await client.get(f"http://{device}/", timeout=1) |
93 | 93 | response.raise_for_status() |
94 | 94 | except httpx.HTTPError as error: |
95 | 95 | _LOGGER.debug("Error encountered: %s", error) |
@@ -160,7 +160,7 @@ async def post_request(client: httpx.AsyncClient, device: str, data: dict[str, A |
160 | 160 |
|
161 | 161 | # XXX: Add retry, recuair devices are often irresponsive. |
162 | 162 | def _wrap_retry(func: Callable[..., X]) -> Callable[..., X]: |
163 | | - return retry(reraise=True, stop=stop_after_attempt(10), wait=wait_exponential(max=30))(func) |
| 163 | + return retry(reraise=True, stop=stop_after_attempt(20), wait=wait_fixed(1))(func) |
164 | 164 |
|
165 | 165 |
|
166 | 166 | async def _run(options: dict[str, str]) -> None: # noqa: C901 |
|
0 commit comments