You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2021/04/08 05:37:27 UTC
[flink-statefun] 02/02: [hotfix][python] fix bad interpolation
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 379957c557d74ab01f23df3fbb51f891197c25fe
Author: Seth Wiesman <sj...@gmail.com>
AuthorDate: Tue Apr 6 17:47:40 2021 -0500
[hotfix][python] fix bad interpolation
This closes #220.
---
statefun-sdk-python/statefun/statefun_builder.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/statefun-sdk-python/statefun/statefun_builder.py b/statefun-sdk-python/statefun/statefun_builder.py
index ade3b63..8d14a69 100644
--- a/statefun-sdk-python/statefun/statefun_builder.py
+++ b/statefun-sdk-python/statefun/statefun_builder.py
@@ -58,7 +58,7 @@ class StatefulFunctions(object):
sig = inspect.getfullargspec(fun)
if len(sig.args) != 2:
raise ValueError(
- f"The registered function ${typename} does not expect a context and a message but rather {sig.args}.")
+ f"The registered function {typename} does not expect a context and a message but rather {sig.args}.")
self._functions[typename] = StatefulFunction(fun=fun, specs=storage_spec, is_async=is_async)
def bind(self, typename, specs: typing.List[ValueSpec] = None):