Skip to content

Commit d719794

Browse files
committed
add log entry when nothing is recovered at Launch time
1 parent c8253a1 commit d719794

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

dbos/dbos.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ type DBOSContext interface {
7575
Cancel() // Gracefully shutdown the DBOS runtime, waiting for workflows to complete and cleaning up resources
7676

7777
// Workflow operations
78-
RunAsStep(_ DBOSContext, fn StepFunc, opts ...StepOption) (any, error) // Execute a function as a durable step within a workflow
78+
RunAsStep(_ DBOSContext, fn StepFunc, opts ...StepOption) (any, error) // Execute a function as a durable step within a workflow
7979
RunAsWorkflow(_ DBOSContext, fn WorkflowFunc, input any, opts ...WorkflowOption) (WorkflowHandle[any], error) // Start a new workflow execution
8080
Send(_ DBOSContext, input WorkflowSendInput) error // Send a message to another workflow
8181
Recv(_ DBOSContext, input WorkflowRecvInput) (any, error) // Receive a message sent to this workflow
@@ -363,6 +363,8 @@ func (c *dbosContext) Launch() error {
363363
}
364364
if len(recoveryHandles) > 0 {
365365
c.logger.Info("Recovered pending workflows", "count", len(recoveryHandles))
366+
} else {
367+
c.logger.Info("No pending workflows to recover")
366368
}
367369

368370
c.logger.Info("DBOS initialized", "app_version", c.applicationVersion, "executor_id", c.executorID)

0 commit comments

Comments
 (0)