just dont warn

Author: maxdml

dbos/dbos.go

@@ -68,7 +68,6 @@ var dbos *executor
 
 func getExecutor() *executor {
 	if dbos == nil {
-		fmt.Println("warning: DBOS instance not initiliazed")
 		return nil
 	}
 	return dbos
@@ -142,9 +141,6 @@ func Launch(options ...LaunchOption) error {
 	// Create context with cancel function for queue runner
 	ctx, cancel := context.WithCancel(context.Background())
 
-	// Create the internal workflow queue
-	NewWorkflowQueue(DBOS_INTERNAL_QUEUE_NAME)
-
 	dbos = &executor{
 		systemDB:              systemDB,
 		queueRunnerCtx:        ctx,

dbos/logger_test.go

@@ -26,8 +26,8 @@ func TestLogger(t *testing.T) {
 		logger.Info("Test message from default logger")
 
 	})
-	t.Run("Custom logger", func(t *testing.T) {
 
+	t.Run("Custom logger", func(t *testing.T) {
 		// Test with custom slog logger
 		var buf bytes.Buffer
 		slogLogger := slog.New(slog.NewTextHandler(&buf, &slog.HandlerOptions{

dbos/queue.go

@@ -16,6 +16,7 @@ import (
 var (
 	workflowQueueRegistry    = make(map[string]WorkflowQueue)
 	DBOS_INTERNAL_QUEUE_NAME = "_dbos_internal_queue"
+	_                        = NewWorkflowQueue(DBOS_INTERNAL_QUEUE_NAME)
 )
 
 // RateLimiter represents a rate limiting configuration