This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from df792ac [FLINK-20265] [core] Implement new extended protocol in
RequestReplyFunction
add f67f8e7 [hotfix] [core] Rename http-function.proto to
request-reply.proto
add 6b3ec55 [FLINK-20268] [python] Regenerate Python SDK protocol
Protobuf messages for new protocol
new 07c29cf [FLINK-20268] [python] Add StateSpec registration to Python
SDK
new e0d7e92 [hotfix] [python, test] Simplify function binding in
request_reply_test
new b522652 [FLINK-20268] [python] Detect missing states and respond
IncompleteInvocationContext
new 280bbe1 [hotfix] [python, test] Remove useless print in tests
new 7ab6172 [FLINK-20268] Update statefun-python-walkthrough-example to
cover new protocol
new f1b30fb [FLINK-20268] [python] Update all Python examples to declare
state with SDK
new be8a94c [FLINK-20268] [core] Declare states with Python SDK in E2E
tests
new e82c2a0 [FLINK-20268] [python, docs] Update Python SDK README.md
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/python/functions.py | 5 +-
.../src/test/resources/remote-module/module.yaml | 2 -
.../greeter/greeter.py | 5 +-
.../statefun/module.yaml | 2 -
.../greeter/greeter.py | 5 +-
.../statefun-python-greeter-example/module.yaml | 2 -
.../statefun-python-k8s-example/main.py | 6 +-
.../statefun-python-k8s-example/module.yaml | 2 -
.../run-example.py | 8 +
.../walkthrough.py | 46 +++--
.../{http-function.proto => request-reply.proto} | 0
statefun-python-sdk/README.md | 46 ++---
statefun-python-sdk/statefun/__init__.py | 4 +
statefun-python-sdk/statefun/core.py | 58 +++++-
statefun-python-sdk/statefun/request_reply.py | 86 +++++++--
statefun-python-sdk/statefun/request_reply_pb2.py | 203 +++++++++++++++++++--
statefun-python-sdk/tests/request_reply_test.py | 165 +++++++++++++++--
statefun-python-sdk/tests/statefun_test.py | 20 +-
statefun-python-sdk/tests/type_deduction_test.py | 1 -
19 files changed, 563 insertions(+), 103 deletions(-)
rename
statefun-flink/statefun-flink-core/src/main/protobuf/{http-function.proto =>
request-reply.proto} (100%)
