Compare commits
No commits in common. "6de23bc6161a2a6101cb86a01fe43637b41b8553" and "00459d0fb7e95fcacb540a63a3193c47ded7549f" have entirely different histories.
6de23bc616
...
00459d0fb7
@ -1,25 +0,0 @@
|
|||||||
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
|
|
||||||
|
|
||||||
@ -1,25 +0,0 @@
|
|||||||
From f0bc203c52b417bf815ac2b0dffbd1f2cd744a8f Mon Sep 17 00:00:00 2001
|
|
||||||
From: Ask Solem <asksol@robinhood.com>
|
|
||||||
Date: Mon, 26 Nov 2018 10:26:04 -0800
|
|
||||||
Subject: [PATCH] Fixes test issue after table serializer choice pull req
|
|
||||||
|
|
||||||
---
|
|
||||||
t/unit/stores/test_base.py | 2 ++
|
|
||||||
1 file changed, 2 insertions(+)
|
|
||||||
|
|
||||||
diff --git a/t/unit/stores/test_base.py b/t/unit/stores/test_base.py
|
|
||||||
index 0c663718..39cdb072 100644
|
|
||||||
--- a/t/unit/stores/test_base.py
|
|
||||||
+++ b/t/unit/stores/test_base.py
|
|
||||||
@@ -125,6 +125,8 @@ class test_SerializedStore:
|
|
||||||
url='foo://',
|
|
||||||
app=app,
|
|
||||||
table=Mock(name='table'),
|
|
||||||
+ key_serializer='json',
|
|
||||||
+ value_serializer='json',
|
|
||||||
)
|
|
||||||
|
|
||||||
def test_apply_changelog_batch(self, *, store):
|
|
||||||
--
|
|
||||||
2.33.0
|
|
||||||
|
|
||||||
@ -1,34 +0,0 @@
|
|||||||
From 12ebcf87c858ede721572a6db3fe63bb3addddbf Mon Sep 17 00:00:00 2001
|
|
||||||
From: Ask Solem <asksol@robinhood.com>
|
|
||||||
Date: Fri, 16 Nov 2018 09:52:22 -0800
|
|
||||||
Subject: [PATCH] loghandlers is list of Handler not StreamHandler
|
|
||||||
|
|
||||||
---
|
|
||||||
faust/types/settings.py | 4 ++--
|
|
||||||
1 file changed, 2 insertions(+), 2 deletions(-)
|
|
||||||
|
|
||||||
diff --git a/faust/types/settings.py b/faust/types/settings.py
|
|
||||||
index fc2e15e1..0fb0aff8 100644
|
|
||||||
--- a/faust/types/settings.py
|
|
||||||
+++ b/faust/types/settings.py
|
|
||||||
@@ -265,7 +265,7 @@ class Settings(abc.ABC):
|
|
||||||
table_standby_replicas: int = 1
|
|
||||||
topic_replication_factor: int = 1
|
|
||||||
topic_partitions: int = 8 # noqa: E704
|
|
||||||
- loghandlers: List[logging.StreamHandler]
|
|
||||||
+ loghandlers: List[logging.Handler]
|
|
||||||
producer_linger_ms: int = PRODUCER_LINGER_MS
|
|
||||||
producer_max_batch_size: int = PRODUCER_MAX_BATCH_SIZE
|
|
||||||
producer_acks: int = PRODUCER_ACKS
|
|
||||||
@@ -366,7 +366,7 @@ class Settings(abc.ABC):
|
|
||||||
tabledir: Union[Path, str] = None,
|
|
||||||
key_serializer: CodecArg = None,
|
|
||||||
value_serializer: CodecArg = None,
|
|
||||||
- loghandlers: List[logging.StreamHandler] = None,
|
|
||||||
+ loghandlers: List[logging.Handler] = None,
|
|
||||||
table_cleanup_interval: Seconds = None,
|
|
||||||
table_standby_replicas: int = None,
|
|
||||||
topic_replication_factor: int = None,
|
|
||||||
--
|
|
||||||
2.33.0
|
|
||||||
|
|
||||||
Binary file not shown.
@ -1,99 +0,0 @@
|
|||||||
%global _empty_manifest_terminate_build 0
|
|
||||||
Name: python-faust
|
|
||||||
Version: 1.3.0
|
|
||||||
Release: 5
|
|
||||||
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
|
|
||||||
Patch0002: backport-loghandlers-is-list-of-Handler-not-StreamHandler.patch
|
|
||||||
Patch0003: backport-Fixes-test-issue-after-table-serializer-choice-pull-.patch
|
|
||||||
|
|
||||||
BuildArch: noarch
|
|
||||||
BuildRequires: python3
|
|
||||||
BuildRequires: python3-aiohttp
|
|
||||||
BuildRequires: python3-click
|
|
||||||
BuildRequires: python3-devel
|
|
||||||
BuildRequires: python3-setuptools
|
|
||||||
BuildRequires: python3-colorclass
|
|
||||||
BuildRequires: python3-mode
|
|
||||||
BuildRequires: python3-terminaltables
|
|
||||||
BuildRequires: python3-yarl
|
|
||||||
%description
|
|
||||||
Python Stream processing.
|
|
||||||
|
|
||||||
%package -n python3-faust
|
|
||||||
Summary: Python Stream processing.
|
|
||||||
Provides: python-faust
|
|
||||||
|
|
||||||
%description -n python3-faust
|
|
||||||
Python Stream processing.
|
|
||||||
|
|
||||||
%package help
|
|
||||||
Summary: Development documents and examples for faust
|
|
||||||
Provides: python3-faust-doc
|
|
||||||
%description help
|
|
||||||
Development documents and examples for faust.
|
|
||||||
|
|
||||||
%prep
|
|
||||||
%autosetup -n faust-%{version} -p1
|
|
||||||
#compitable to openEuler
|
|
||||||
sed -i 's/mode>=2.0.3,<3.0/mode>=4.4.0/g' requirements/default.txt
|
|
||||||
sed -i 's/click>=6.7,<7.0/click>=7.0/g' requirements/default.txt
|
|
||||||
sed -i '2d;7d' requirements/default.txt
|
|
||||||
|
|
||||||
%build
|
|
||||||
%py3_build
|
|
||||||
|
|
||||||
%install
|
|
||||||
%py3_install
|
|
||||||
install -d -m755 %{buildroot}/%{_pkgdocdir}
|
|
||||||
if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi
|
|
||||||
if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi
|
|
||||||
if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi
|
|
||||||
if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi
|
|
||||||
pushd %{buildroot}
|
|
||||||
if [ -d usr/lib ]; then
|
|
||||||
find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst
|
|
||||||
fi
|
|
||||||
if [ -d usr/lib64 ]; then
|
|
||||||
find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst
|
|
||||||
fi
|
|
||||||
if [ -d usr/bin ]; then
|
|
||||||
find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst
|
|
||||||
fi
|
|
||||||
if [ -d usr/sbin ]; then
|
|
||||||
find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst
|
|
||||||
fi
|
|
||||||
touch doclist.lst
|
|
||||||
if [ -d usr/share/man ]; then
|
|
||||||
find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst
|
|
||||||
fi
|
|
||||||
popd
|
|
||||||
mv %{buildroot}/filelist.lst .
|
|
||||||
mv %{buildroot}/doclist.lst .
|
|
||||||
|
|
||||||
%files -n python3-faust -f filelist.lst
|
|
||||||
%dir %{python3_sitelib}/*
|
|
||||||
|
|
||||||
%files help -f doclist.lst
|
|
||||||
%{_docdir}/*
|
|
||||||
|
|
||||||
%changelog
|
|
||||||
* Mon Jan 9 2023 Bolehu <heyaohua@xfusion.com> - 1.3.0-5
|
|
||||||
- Fixes test issue after table serializer choice pull req
|
|
||||||
|
|
||||||
* Mon Jan 9 2023 Bolehu <heyaohua@xfusion.com> - 1.3.0-4
|
|
||||||
- loghandlers is list of Handler not StreamHandler
|
|
||||||
|
|
||||||
* Sat Jan 7 2023 Bolehu <heyaohua@xfusion.com> - 1.3.0-3
|
|
||||||
- Fixes missing await in consumer.wait_empty
|
|
||||||
|
|
||||||
* Fri Aug 27 2021 wutao <wutao61@huawei.com> - 1.3.0-2
|
|
||||||
- Change faust.tar.gz source from github to pypi to
|
|
||||||
compatible with openEuler
|
|
||||||
|
|
||||||
* Thu Jul 22 2021 wutao <wutao61@huawei.com> - 1.3.0-1
|
|
||||||
- Package init
|
|
||||||
Loading…
x
Reference in New Issue
Block a user