Merge pull request #8 from wanjunlei/release-1.0

fix bug java async function run failed in dapr proxy mode
OpenFunction · Mar 9, 2023 · 7459992 · 7459992
2 parents 73321fd + 3401c0b
commit 7459992
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/functions-framework-api/pom.xml b/functions-framework-api/pom.xml
@@ -32,7 +32,7 @@
 
   <groupId>dev.openfunction.functions</groupId>
   <artifactId>functions-framework-api</artifactId>
-  <version>1.0.0</version>
+  <version>1.0.1</version>
 
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

diff --git a/functions-framework-invoker/pom.xml b/functions-framework-invoker/pom.xml
@@ -10,7 +10,7 @@
 
     <groupId>dev.openfunction.functions</groupId>
     <artifactId>functions-framework-invoker</artifactId>
-    <version>1.0.0</version>
+    <version>1.0.1</version>
 
     <properties>
         <maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>

diff --git a/...framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java b/...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/...-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java b/...-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);
         }