Projects
Eulaceura:Factory
python-faust
_service:obs_scm:backport-Fixes-missing-await-i...
Sign Up
Log In
Username
Password
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File _service:obs_scm:backport-Fixes-missing-await-in-consumer.wait_empty.patch of Package python-faust
From 2a9cb8970b051e2536958bf7690b9cdaa22e3b55 Mon Sep 17 00:00:00 2001 From: Ask Solem <asksol@robinhood.com> Date: Mon, 19 Nov 2018 13:00:47 -0800 Subject: [PATCH] Fixes missing `await` in consumer.wait_empty --- faust/transport/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faust/transport/consumer.py b/faust/transport/consumer.py index 17e60fab..873356d8 100644 --- a/faust/transport/consumer.py +++ b/faust/transport/consumer.py @@ -300,7 +300,7 @@ class Consumer(Service, ConsumerT): self._waiting_for_ack = asyncio.Future(loop=self.loop) try: # wait for `ack()` to wake us up - asyncio.wait_for( + await asyncio.wait_for( self._waiting_for_ack, loop=self.loop, timeout=1) except (asyncio.TimeoutError, asyncio.CancelledError): # pragma: no cover -- 2.33.0
Locations
Projects
Search
Status Monitor
Help
Open Build Service
OBS Manuals
API Documentation
OBS Portal
Reporting a Bug
Contact
Mailing List
Forums
Chat (IRC)
Twitter
Open Build Service (OBS)
is an
openSUSE project
.
浙ICP备2022010568号-2