From ea6e4ace80ab2de2c077218addaeb78b5e9c355e Mon Sep 17 00:00:00 2001 From: CoprDistGit Date: Tue, 11 Apr 2023 23:46:02 +0000 Subject: automatic import of python-statefun-tasks --- .gitignore | 1 + python-statefun-tasks.spec | 161 +++++++++++++++++++++++++++++++++++++++++++++ sources | 1 + 3 files changed, 163 insertions(+) create mode 100644 python-statefun-tasks.spec create mode 100644 sources diff --git a/.gitignore b/.gitignore index e69de29..4f2dc07 100644 --- a/.gitignore +++ b/.gitignore @@ -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 - 0.9.91-1 +- Package Spec generated diff --git a/sources b/sources new file mode 100644 index 0000000..1db9499 --- /dev/null +++ b/sources @@ -0,0 +1 @@ +fd447d9771c22994f436637d2acd5f86 statefun-tasks-0.9.91.tar.gz -- cgit v1.2.3