diff --git a/backport-Fixes-missing-await-in-consumer.wait_empty.patch b/backport-Fixes-missing-await-in-consumer.wait_empty.patch new file mode 100644 index 0000000..5c5e171 --- /dev/null +++ b/backport-Fixes-missing-await-in-consumer.wait_empty.patch @@ -0,0 +1,25 @@ +From 2a9cb8970b051e2536958bf7690b9cdaa22e3b55 Mon Sep 17 00:00:00 2001 +From: Ask Solem +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 + diff --git a/python-faust.spec b/python-faust.spec index 6926844..e797d90 100644 --- a/python-faust.spec +++ b/python-faust.spec @@ -1,11 +1,14 @@ %global _empty_manifest_terminate_build 0 Name: python-faust Version: 1.3.0 -Release: 2 +Release: 3 Summary: Python Stream processing. License: BSD 3-Clause and CC-BY-SA-4.0 URL: http://faust.readthedocs.io/ Source0: https://files.pythonhosted.org/packages/91/c3/75878084aba2bbcf680b0c57f00b9586b0b9d84a74695260b489666e579b/faust-1.3.0.tar.gz + +Patch0001: backport-Fixes-missing-await-in-consumer.wait_empty.patch + BuildArch: noarch BuildRequires: python3 BuildRequires: python3-aiohttp @@ -77,6 +80,9 @@ mv %{buildroot}/doclist.lst . %{_docdir}/* %changelog +* Sat Jan 7 2023 Bolehu - 1.3.0-3 +- Fixes missing await in consumer.wait_empty + * Fri Aug 27 2021 wutao - 1.3.0-2 - Change faust.tar.gz source from github to pypi to compatible with openEuler