summaryrefslogtreecommitdiff
path: root/python-statefun-tasks.spec
diff options
context:
space:
mode:
authorCoprDistGit <infra@openeuler.org>2023-04-11 23:46:02 +0000
committerCoprDistGit <infra@openeuler.org>2023-04-11 23:46:02 +0000
commitea6e4ace80ab2de2c077218addaeb78b5e9c355e (patch)
tree7b19cf0efec118bd8d59ee82baffd586e630c170 /python-statefun-tasks.spec
parentc82a0ee338a993c2c740f50ab14c720873dabe7f (diff)
automatic import of python-statefun-tasks
Diffstat (limited to 'python-statefun-tasks.spec')
-rw-r--r--python-statefun-tasks.spec161
1 files changed, 161 insertions, 0 deletions
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