%global _empty_manifest_terminate_build 0 Name: python-statefun-tasks Version: 0.9.92 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/96/a8/ef5430f14729831226a3cc83ff9b379458cd203fb1b9df9af9e27f158dc5/statefun-tasks-0.9.92.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.92 %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 25 2023 Python_Bot - 0.9.92-1 - Package Spec generated