for now return a flat error if we try to enqueue a workflow in a different queu

Author: maxdml

dbos/queues_test.go

@@ -297,7 +297,7 @@ func TestWorkflowQueues(t *testing.T) {
 		}
 
 		// Check that the error message contains queue information
-		expectedMsgPart := "different queue"
+		expectedMsgPart := "Workflow already exists in a different queue"
 		if !strings.Contains(err.Error(), expectedMsgPart) {
 			t.Fatalf("expected error message to contain '%s', got '%s'", expectedMsgPart, err.Error())
 		}

dbos/system_database.go

@@ -380,7 +380,7 @@ func (s *systemDatabase) InsertWorkflowStatus(ctx context.Context, input insertW
 		return nil, newConflictingWorkflowError(input.status.ID, fmt.Sprintf("Workflow already exists with a different name: %s, but the provided name is: %s", result.name, input.status.Name))
 	}
 	if len(input.status.QueueName) > 0 && result.queueName != nil && input.status.QueueName != *result.queueName {
-		s.logger.Warn("Queue name conflict for workflow", "workflow_id", input.status.ID, "result_queue", *result.queueName, "status_queue", input.status.QueueName)
+		return nil, newConflictingWorkflowError(input.status.ID, fmt.Sprintf("Workflow already exists in a different queue: %s, but the provided queue is: %s", *result.queueName, input.status.QueueName))
 	}
 
 	// Every time we start executing a workflow (and thus attempt to insert its status), we increment `recovery_attempts` by 1.