diff options
| -rw-r--r-- | .gitignore | 1 | ||||
| -rw-r--r-- | python-statefun-tasks.spec | 161 | ||||
| -rw-r--r-- | sources | 1 |
3 files changed, 163 insertions, 0 deletions
@@ -0,0 +1 @@ +/statefun-tasks-0.9.91.tar.gz diff --git a/python-statefun-tasks.spec b/python-statefun-tasks.spec new file mode 100644 index 0000000..183dd7b --- /dev/null +++ b/python-statefun-tasks.spec @@ -0,0 +1,161 @@ +%global _empty_manifest_terminate_build 0 +Name: python-statefun-tasks +Version: 0.9.91 +Release: 1 +Summary: Tasks API for Stateful Functions on Flink +License: https://www.apache.org/licenses/LICENSE-2.0 +URL: https://fransking.github.io/flink-statefun-tasks +Source0: https://mirrors.nju.edu.cn/pypi/web/packages/2a/55/5903d28e9f23176b9b02db78699117f51facdd69c11194951d27bbdae6d8/statefun-tasks-0.9.91.tar.gz +BuildArch: noarch + +Requires: python3-apache-flink-statefun +Requires: python3-kafka-python + +%description +# Flink Tasks +Tasks API for Stateful Functions on Flink + +## What is it? + +A lightweight API that borrows concepts from Celery to allow Python developers to run task based workflows on Apache Flink Stateful Functions. Workflows are composed of Tasks which accept parameters and can be chained together as continuations into a Pipeline. The Pipeline becomes the Flink state. + + +``` +@tasks.bind() +def greeting_workflow(first_name, last_name): + return say_hello.send(first_name, last_name).continue_with(say_goodbye) + + +@tasks.bind() +def say_hello(first_name, last_name): + return f'Hello {first_name} {last_name}' + + +@tasks.bind() +def say_goodbye(greeting): + return f'{greeting}. So now I will say goodbye' +``` + +Try the [demo](https://flink-demo-az.sbbsystems.co.uk). + +Additional documentation can be found [here](https://fransking.github.io/flink-statefun-tasks). + + + + +%package -n python3-statefun-tasks +Summary: Tasks API for Stateful Functions on Flink +Provides: python-statefun-tasks +BuildRequires: python3-devel +BuildRequires: python3-setuptools +BuildRequires: python3-pip +%description -n python3-statefun-tasks +# Flink Tasks +Tasks API for Stateful Functions on Flink + +## What is it? + +A lightweight API that borrows concepts from Celery to allow Python developers to run task based workflows on Apache Flink Stateful Functions. Workflows are composed of Tasks which accept parameters and can be chained together as continuations into a Pipeline. The Pipeline becomes the Flink state. + + +``` +@tasks.bind() +def greeting_workflow(first_name, last_name): + return say_hello.send(first_name, last_name).continue_with(say_goodbye) + + +@tasks.bind() +def say_hello(first_name, last_name): + return f'Hello {first_name} {last_name}' + + +@tasks.bind() +def say_goodbye(greeting): + return f'{greeting}. So now I will say goodbye' +``` + +Try the [demo](https://flink-demo-az.sbbsystems.co.uk). + +Additional documentation can be found [here](https://fransking.github.io/flink-statefun-tasks). + + + + +%package help +Summary: Development documents and examples for statefun-tasks +Provides: python3-statefun-tasks-doc +%description help +# Flink Tasks +Tasks API for Stateful Functions on Flink + +## What is it? + +A lightweight API that borrows concepts from Celery to allow Python developers to run task based workflows on Apache Flink Stateful Functions. Workflows are composed of Tasks which accept parameters and can be chained together as continuations into a Pipeline. The Pipeline becomes the Flink state. + + +``` +@tasks.bind() +def greeting_workflow(first_name, last_name): + return say_hello.send(first_name, last_name).continue_with(say_goodbye) + + +@tasks.bind() +def say_hello(first_name, last_name): + return f'Hello {first_name} {last_name}' + + +@tasks.bind() +def say_goodbye(greeting): + return f'{greeting}. So now I will say goodbye' +``` + +Try the [demo](https://flink-demo-az.sbbsystems.co.uk). + +Additional documentation can be found [here](https://fransking.github.io/flink-statefun-tasks). + + + + +%prep +%autosetup -n statefun-tasks-0.9.91 + +%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-statefun-tasks -f filelist.lst +%dir %{python3_sitelib}/* + +%files help -f doclist.lst +%{_docdir}/* + +%changelog +* Tue Apr 11 2023 Python_Bot <Python_Bot@openeuler.org> - 0.9.91-1 +- Package Spec generated @@ -0,0 +1 @@ +fd447d9771c22994f436637d2acd5f86 statefun-tasks-0.9.91.tar.gz |