From 5245529a12afac677b2aa5ab23fae3e6b0a34a51 Mon Sep 17 00:00:00 2001 From: Sanjeev Kulkarni Date: Fri, 2 Mar 2018 14:58:18 -0800 Subject: [PATCH] Effectively once not yet supported in Python (#278) --- .../java/org/apache/pulsar/admin/cli/CmdFunctions.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/pulsar-functions/cli/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java b/pulsar-functions/cli/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java index 9d141accddd..f31135e2f74 100644 --- a/pulsar-functions/cli/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java +++ b/pulsar-functions/cli/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java @@ -215,7 +215,7 @@ public class CmdFunctions extends CmdBase { functionConfigBuilder.setRuntime(FunctionConfig.Runtime.JAVA); userCodeFile = jarFile; } else if (null != pyFile) { - // Can we do any checks here? + doPythonSubmitChecks(functionConfigBuilder); functionConfigBuilder.setRuntime(FunctionConfig.Runtime.PYTHON); userCodeFile = pyFile; } else { @@ -365,6 +365,12 @@ public class CmdFunctions extends CmdBase { } } + private void doPythonSubmitChecks(FunctionConfig.Builder functionConfigBuilder) { + if (functionConfigBuilder.getProcessingGuarantees() == FunctionConfig.ProcessingGuarantees.EFFECTIVELY_ONCE) { + throw new RuntimeException("Effectively once not yet supported in python"); + } + } + private void inferMissingArguments(FunctionConfig.Builder builder) { if (builder.getName() == null || builder.getName().isEmpty()) { inferMissingFunctionName(builder); -- GitLab