diff --git a/functions-framework-api/pom.xml b/functions-framework-api/pom.xml index c69ae104..d100869d 100644 --- a/functions-framework-api/pom.xml +++ b/functions-framework-api/pom.xml @@ -32,7 +32,7 @@ dev.openfunction.functions functions-framework-api - 1.0.0 + 1.0.1 UTF-8 diff --git a/functions-framework-invoker/pom.xml b/functions-framework-invoker/pom.xml index f35453ec..c087a900 100644 --- a/functions-framework-invoker/pom.xml +++ b/functions-framework-invoker/pom.xml @@ -10,7 +10,7 @@ dev.openfunction.functions functions-framework-invoker - 1.0.0 + 1.0.1 3.8.0 diff --git a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java b/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java index cc5d81fd..0d478f0b 100644 --- a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java +++ b/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java @@ -88,7 +88,6 @@ private class Service extends AppCallbackGrpc.AppCallbackImplBase { private DaprClient daprClient; public void start(int port) throws Exception { - daprServer = ServerBuilder .forPort(port) .addService(Service.this) diff --git a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java b/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java index f6f4767a..23083d60 100644 --- a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java +++ b/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java @@ -62,7 +62,8 @@ public SynchronizeRuntime(RuntimeContext runtimeContext, Class[] functionClas @Override public void start() throws Exception { // create dapr client when dapr sidecar enabled. - if (System.getenv("DAPR_GRPC_PORT") != null || System.getenv("DAPR_HTTP_PORT") != null) { + if ((runtimeContext.getInputs() != null && !runtimeContext.getInputs().isEmpty()) || + (runtimeContext.getOutputs() != null && !runtimeContext.getOutputs().isEmpty())) { daprClient = new DaprClientBuilder().build(); daprClient.waitForSidecar(Runtime.WaitDaprSidecarTimeout); }