!14 Fixes missing await in consumer.wait_empty

From: @Bolehu 
Reviewed-by: @Charlie_li 
Signed-off-by: @Charlie_li
This commit is contained in:
openeuler-ci-bot 2023-01-09 06:18:16 +00:00 committed by Gitee
commit 651ef59240
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
2 changed files with 32 additions and 1 deletions

View File

@ -0,0 +1,25 @@
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

View File

@ -1,11 +1,14 @@
%global _empty_manifest_terminate_build 0 %global _empty_manifest_terminate_build 0
Name: python-faust Name: python-faust
Version: 1.3.0 Version: 1.3.0
Release: 1 Release: 2
Summary: Python Stream processing. Summary: Python Stream processing.
License: BSD 3-Clause and CC-BY-SA-4.0 License: BSD 3-Clause and CC-BY-SA-4.0
URL: http://faust.readthedocs.io/ URL: http://faust.readthedocs.io/
Source0: https://github.com/robinhood/faust/archive/refs/tags/v%{version}.tar.gz Source0: https://github.com/robinhood/faust/archive/refs/tags/v%{version}.tar.gz
Patch0001: backport-Fixes-missing-await-in-consumer.wait_empty.patch
BuildArch: noarch BuildArch: noarch
BuildRequires: python3 BuildRequires: python3
BuildRequires: python3-aiohttp BuildRequires: python3-aiohttp
@ -77,5 +80,8 @@ mv %{buildroot}/doclist.lst .
%{_docdir}/* %{_docdir}/*
%changelog %changelog
* Sat Jan 7 2023 Bolehu <heyaohua@xfusion.com> - 1.3.0-2
- Fixes missing await in consumer.wait_empty
* Thu Jul 22 2021 wutao <wutao61@huawei.com> - 1.3.0-1 * Thu Jul 22 2021 wutao <wutao61@huawei.com> - 1.3.0-1
- Package init - Package init