diff --git a/light9/collector/collector_client_asyncio.py b/light9/collector/collector_client_asyncio.py --- a/light9/collector/collector_client_asyncio.py +++ b/light9/collector/collector_client_asyncio.py @@ -1,5 +1,4 @@ import logging -import tenacity from light9 import networking from light9.collector.collector_client import toCollectorJson from light9.effect.settings import DeviceSettings @@ -20,13 +19,7 @@ class _Sender: async def send(self, client: str, session: str, settings: DeviceSettings): msg = toCollectorJson(client, session, settings).encode('utf8') - @tenacity.retry( - retry=tenacity.retry_if_exception_type(aiohttp.ServerTimeoutError), - reraise=True, - stop=tenacity.stop_after_attempt(3), - ) async def put(): - async with self.http_session.put(networking.collector.path('attrs'), data=msg, timeout=.2) as resp: if resp.status != 202: body = await resp.text() @@ -34,9 +27,6 @@ class _Sender: raise ValueError(f'collector returned {resp.status}: {body}') await put() - attempts = put.retry.statistics['attempt_number'] - if attempts!=1: - log.warning(f"{attempts=}") _sender = _Sender()