Bump log level for invocation start/stop to info

restatedev · Dec 20, 2023 · 770cfe8 · 770cfe8
1 parent e95eeed
commit 770cfe8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sdk-core/src/main/java/dev/restate/sdk/core/InvocationStateMachine.java b/sdk-core/src/main/java/dev/restate/sdk/core/InvocationStateMachine.java
@@ -205,7 +205,7 @@ void onStart(MessageLite msg) {
   void close() {
     if (this.invocationState != InvocationState.CLOSED) {
       this.transitionState(InvocationState.CLOSED);
-      LOG.debug("Closing state machine");
+      LOG.info("Stopped processing invocation");
 
       // Cancel inputSubscription and complete outputSubscriber
       if (inputSubscription != null) {
@@ -227,7 +227,7 @@ void close() {
   void fail(Throwable cause) {
     if (this.invocationState != InvocationState.CLOSED) {
       this.transitionState(InvocationState.CLOSED);
-      LOG.debug("Closing state machine with failure", cause);
+      LOG.warn("Stopped processing invocation with failure", cause);
 
       // Cancel inputSubscription and complete outputSubscriber
       if (inputSubscription != null) {

diff --git a/sdk-core/src/main/java/dev/restate/sdk/core/RestateGrpcServer.java b/sdk-core/src/main/java/dev/restate/sdk/core/RestateGrpcServer.java
@@ -111,7 +111,7 @@ public InvocationFlow.InvocationOutputPublisher output() {
 
       @Override
       public void start() {
-        LOG.debug("Start processing call to {}/{}", serviceName, methodName);
+        LOG.info("Start processing invocation");
         stateMachine.start(
             invocationId -> {
               // Set invocation id in logging context