diff --git a/elasticsearch/_async/transport.py b/elasticsearch/_async/transport.py index f7a2b2f51..aae6e37f2 100644 --- a/elasticsearch/_async/transport.py +++ b/elasticsearch/_async/transport.py @@ -132,7 +132,7 @@ async def _async_call(self): await self._async_init() if self.sniffer_timeout: - if self.loop.time() >= self.last_sniff + self.sniff_timeout: + if self.loop.time() >= self.last_sniff + self.sniffer_timeout: self.create_sniff_task() async def _get_node_info(self, conn, initial):