RunAsWorkflow -> RunWorkflow

Author: maxdml

.github/workflows/security.yml

@@ -18,7 +18,7 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
-    - uses: actions/checkout@v4
+    - uses: actions/checkout@v5
       with:
         fetch-depth: 0
 

.github/workflows/tests.yml

@@ -34,7 +34,7 @@ jobs:
           - 5432:5432
 
     steps:
-    - uses: actions/checkout@v4
+    - uses: actions/checkout@v5
       with:
         fetch-depth: 0
         fetch-tags: true

README.md

@@ -93,7 +93,7 @@ func main() {
 	defer ctx.Cancel()
 
     // Run a durable workflow and get its result
-	handle, err := dbos.RunAsWorkflow(ctx, workflow, "")
+	handle, err := dbos.RunWorkflow(ctx, workflow, "")
 	if err != nil {
 		panic(err)
 	}
@@ -170,7 +170,7 @@ func main() {
     fmt.Println("Enqueuing workflows")
     handles := make([]dbos.WorkflowHandle[int], 10)
     for i := range 10 {
-        handle, err := dbos.RunAsWorkflow(ctx, task, i, dbos.WithQueue(queue.Name))
+        handle, err := dbos.RunWorkflow(ctx, task, i, dbos.WithQueue(queue.Name))
         if err != nil {
             panic(fmt.Sprintf("failed to enqueue step %d: %v", i, err))
         }
@@ -199,7 +199,7 @@ Acknowledge the event immediately while reliably processing it in the background
 For example:
 
 ```golang
-_, err := dbos.RunAsWorkflow(ctx, task, i, dbos.WithWorkflowID(exactlyOnceEventID))
+_, err := dbos.RunWorkflow(ctx, task, i, dbos.WithWorkflowID(exactlyOnceEventID))
 ```
 </details>
 
@@ -224,7 +224,7 @@ func workflow(ctx dbos.DBOSContext, duration time.Duration) (string, error) {
     return fmt.Sprintf("Workflow slept for %s", duration), nil
 }
 
-handle, err := dbos.RunAsWorkflow(dbosCtx, workflow, time.Second*5)
+handle, err := dbos.RunWorkflow(dbosCtx, workflow, time.Second*5)
 _, err = handle.GetResult()
 ```
 
@@ -251,10 +251,10 @@ func receiveWorkflow(ctx dbos.DBOSContext, topic string) (string, error) {
 }
 
 // Start a receiver in the background
-recvHandle, err := dbos.RunAsWorkflow(dbosCtx, receiveWorkflow, "topic", dbos.WithWorkflowID("receiverID"))
+recvHandle, err := dbos.RunWorkflow(dbosCtx, receiveWorkflow, "topic", dbos.WithWorkflowID("receiverID"))
 
 // Send a message
-sendHandle, err := dbos.RunAsWorkflow(dbosCtx, sendWorkflow, "hola!")
+sendHandle, err := dbos.RunWorkflow(dbosCtx, sendWorkflow, "hola!")
 _, err = sendHandle.GetResult()
 
 // Eventually get the response

dbos/admin_server_test.go

@@ -262,22 +262,22 @@ func TestAdminServer(t *testing.T) {
 
 		// Create workflows with different input/output types
 		// 1. Integer workflow
-		intHandle, err := RunAsWorkflow(ctx, intWorkflow, 42)
+		intHandle, err := RunWorkflow(ctx, intWorkflow, 42)
 		require.NoError(t, err, "Failed to create int workflow")
 		intResult, err := intHandle.GetResult()
 		require.NoError(t, err, "Failed to get int workflow result")
 		assert.Equal(t, 84, intResult)
 
 		// 2. Empty string workflow
-		emptyStringHandle, err := RunAsWorkflow(ctx, emptyStringWorkflow, "")
+		emptyStringHandle, err := RunWorkflow(ctx, emptyStringWorkflow, "")
 		require.NoError(t, err, "Failed to create empty string workflow")
 		emptyStringResult, err := emptyStringHandle.GetResult()
 		require.NoError(t, err, "Failed to get empty string workflow result")
 		assert.Equal(t, "", emptyStringResult)
 
 		// 3. Struct workflow
 		structInput := TestStruct{Name: "test", Value: 10}
-		structHandle, err := RunAsWorkflow(ctx, structWorkflow, structInput)
+		structHandle, err := RunWorkflow(ctx, structWorkflow, structInput)
 		require.NoError(t, err, "Failed to create struct workflow")
 		structResult, err := structHandle.GetResult()
 		require.NoError(t, err, "Failed to get struct workflow result")
@@ -385,7 +385,7 @@ func TestAdminServer(t *testing.T) {
 		endpoint := fmt.Sprintf("http://localhost:3001/%s", strings.TrimPrefix(_WORKFLOWS_PATTERN, "POST /"))
 
 		// Create first workflow
-		handle1, err := RunAsWorkflow(ctx, testWorkflow, "workflow1")
+		handle1, err := RunWorkflow(ctx, testWorkflow, "workflow1")
 		require.NoError(t, err, "Failed to create first workflow")
 		workflowID1 := handle1.GetWorkflowID()
 
@@ -399,7 +399,7 @@ func TestAdminServer(t *testing.T) {
 		time.Sleep(500 * time.Millisecond)
 
 		// Create second workflow
-		handle2, err := RunAsWorkflow(ctx, testWorkflow, "workflow2")
+		handle2, err := RunWorkflow(ctx, testWorkflow, "workflow2")
 		require.NoError(t, err, "Failed to create second workflow")
 		result2, err := handle2.GetResult()
 		require.NoError(t, err, "Failed to get second workflow result")

dbos/client_test.go

@@ -517,7 +517,7 @@ func TestForkWorkflow(t *testing.T) {
 		}
 
 		// Child workflow 1
-		child1Handle, err := RunAsWorkflow(ctx, childWorkflow1, input)
+		child1Handle, err := RunWorkflow(ctx, childWorkflow1, input)
 		if err != nil {
 			return "", err
 		}
@@ -536,7 +536,7 @@ func TestForkWorkflow(t *testing.T) {
 		}
 
 		// Child workflow 2
-		child2Handle, err := RunAsWorkflow(ctx, childWorkflow2, input)
+		child2Handle, err := RunWorkflow(ctx, childWorkflow2, input)
 		if err != nil {
 			return "", err
 		}

dbos/dbos.go

@@ -102,7 +102,7 @@ type DBOSContext interface {
 
 	// Workflow operations
 	RunAsStep(_ DBOSContext, fn StepFunc, opts ...StepOption) (any, error)                                        // Execute a function as a durable step within a workflow
-	RunAsWorkflow(_ DBOSContext, fn WorkflowFunc, input any, opts ...WorkflowOption) (WorkflowHandle[any], error) // Start a new workflow execution
+	RunWorkflow(_ DBOSContext, fn WorkflowFunc, input any, opts ...WorkflowOption) (WorkflowHandle[any], error) // Start a new workflow execution
 	Send(_ DBOSContext, destinationID string, message any, topic string) error                                    // Send a message to another workflow
 	Recv(_ DBOSContext, topic string, timeout time.Duration) (any, error)                                         // Receive a message sent to this workflow
 	SetEvent(_ DBOSContext, key string, message any) error                                                        // Set a key-value event for this workflow

dbos/queue.go

@@ -81,7 +81,7 @@ func WithMaxTasksPerIteration(maxTasks int) QueueOption {
 }
 
 // NewWorkflowQueue creates a new workflow queue with the specified name and configuration options.
-// The queue must be created before workflows can be enqueued to it using the WithQueue option in RunAsWorkflow.
+// The queue must be created before workflows can be enqueued to it using the WithQueue option in RunWorkflow.
 // Queues provide controlled execution with support for concurrency limits, priority scheduling, and rate limiting.
 //
 // Example:
@@ -96,7 +96,7 @@ func WithMaxTasksPerIteration(maxTasks int) QueueOption {
 //	)
 //
 //	// Enqueue workflows to this queue:
-//	handle, err := dbos.RunAsWorkflow(ctx, SendEmailWorkflow, emailData, dbos.WithQueue("email-queue"))
+//	handle, err := dbos.RunWorkflow(ctx, SendEmailWorkflow, emailData, dbos.WithQueue("email-queue"))
 func NewWorkflowQueue(dbosCtx DBOSContext, name string, options ...QueueOption) WorkflowQueue {
 	ctx, ok := dbosCtx.(*dbosContext)
 	if !ok {