From 264617305514b5fcc567002c24910506a98b0e4e Mon Sep 17 00:00:00 2001 From: raittes Date: Thu, 11 Feb 2021 14:34:13 -0300 Subject: [PATCH] kombu/asynchronous/http/curl: implement _set_timeout --- kombu/asynchronous/http/curl.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kombu/asynchronous/http/curl.py b/kombu/asynchronous/http/curl.py index 9f972469..df9fc7d8 100644 --- a/kombu/asynchronous/http/curl.py +++ b/kombu/asynchronous/http/curl.py @@ -100,7 +100,7 @@ class CurlClient(BaseClient): self._fds[fd] = READ | WRITE def _set_timeout(self, msecs): - pass # TODO + self.hub.call_later(msecs, self._timeout_check) def _timeout_check(self, _pycurl=pycurl): self._pop_from_hub()