From 0c069500ac48c81a96b5ccd212c2bf50b11080f9 Mon Sep 17 00:00:00 2001
From: Harry Pierson <harry.pierson@dbos.dev>
Date: Sat, 20 Dec 2025 09:52:25 -0800
Subject: [PATCH] fix logs in recovery code path

---
 .../dev/dbos/transact/execution/DBOSExecutor.java   | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/transact/src/main/java/dev/dbos/transact/execution/DBOSExecutor.java b/transact/src/main/java/dev/dbos/transact/execution/DBOSExecutor.java
index e7db5afa..8787bd09 100644
--- a/transact/src/main/java/dev/dbos/transact/execution/DBOSExecutor.java
+++ b/transact/src/main/java/dev/dbos/transact/execution/DBOSExecutor.java
@@ -301,18 +301,15 @@ public Optional<Queue> getQueue(String queueName) {
     String workflowId = Objects.requireNonNull(output.workflowId(), "workflowId must not be null");
     String queue = output.queueName();
 
-    logger.debug("recoverWorkflow {}", workflowId);
-
     if (queue != null) {
       boolean cleared = systemDatabase.clearQueueAssignment(workflowId);
       if (cleared) {
-        logger.debug(
-            "recoverWorkflow {} queue assignment {}",
-            workflowId,
-            cleared ? "cleared" : "not cleared");
+        logger.debug("recoverWorkflow clear queue assignment {}", workflowId);
         return retrieveWorkflow(workflowId);
       }
     }
+
+    logger.debug("recoverWorkflow execute {}", workflowId);
     return executeWorkflowById(workflowId, true, false);
   }
 
@@ -336,8 +333,8 @@ public Optional<Queue> getQueue(String queueName) {
       logger.info(
           "Recovering {} workflows for executor {} app version {}",
           pendingWorkflows.size(),
-          executorId(),
-          appVersion());
+          executorId,
+          appVersion);
       for (var output : pendingWorkflows) {
         try {
           handles.add(recoverWorkflow(output));