change function name and run fmt

Author: shirzady1934

dbos/workflow.go

@@ -120,9 +120,9 @@ func WithHandleTimeout(timeout time.Duration) GetResultOption {
 	}
 }
 
-// WithPollingInterval sets the polling interval for awaiting workflow completion in GetResult.
+// WithHandlePollingInterval sets the polling interval for awaiting workflow completion in GetResult.
 // If a non-positive interval is provided, the default interval is used.
-func WithPollingInterval(interval time.Duration) GetResultOption {
+func WithHandlePollingInterval(interval time.Duration) GetResultOption {
 	return func(opts *getResultOptions) {
 		if interval > 0 {
 			opts.pollInterval = interval

dbos/workflows_test.go

@@ -4544,20 +4544,20 @@ func TestWorkflowIdentity(t *testing.T) {
 }
 
 func TestWorkflowHandles(t *testing.T) {
-dbosCtx := setupDBOS(t, true, true)
-RegisterWorkflow(dbosCtx, slowWorkflow)
+	dbosCtx := setupDBOS(t, true, true)
+	RegisterWorkflow(dbosCtx, slowWorkflow)
 
-t.Run("WorkflowHandleTimeout", func(t *testing.T) {
-handle, err := RunWorkflow(dbosCtx, slowWorkflow, 10*time.Second)
-require.NoError(t, err, "failed to start workflow")
+	t.Run("WorkflowHandleTimeout", func(t *testing.T) {
+		handle, err := RunWorkflow(dbosCtx, slowWorkflow, 10*time.Second)
+		require.NoError(t, err, "failed to start workflow")
 
-start := time.Now()
-_, err = handle.GetResult(WithHandleTimeout(10*time.Millisecond), WithPollingInterval(1*time.Millisecond))
-duration := time.Since(start)
+		start := time.Now()
+		_, err = handle.GetResult(WithHandleTimeout(10*time.Millisecond), WithHandlePollingInterval(1*time.Millisecond))
+		duration := time.Since(start)
 
-require.Error(t, err, "expected timeout error")
-assert.Contains(t, err.Error(), "workflow result timeout")
-assert.True(t, duration < 100*time.Millisecond, "timeout should occur quickly")
+		require.Error(t, err, "expected timeout error")
+		assert.Contains(t, err.Error(), "workflow result timeout")
+		assert.True(t, duration < 100*time.Millisecond, "timeout should occur quickly")
 		assert.True(t, errors.Is(err, context.DeadlineExceeded),
 			"expected error to be detectable as context.DeadlineExceeded, got: %v", err)
 	})
@@ -4567,18 +4567,18 @@ assert.True(t, duration < 100*time.Millisecond, "timeout should occur quickly")
 		originalHandle, err := RunWorkflow(dbosCtx, slowWorkflow, 10*time.Second)
 		require.NoError(t, err, "failed to start workflow")
 
-pollingHandle, err := RetrieveWorkflow[string](dbosCtx, originalHandle.GetWorkflowID())
-require.NoError(t, err, "failed to retrieve workflow")
+		pollingHandle, err := RetrieveWorkflow[string](dbosCtx, originalHandle.GetWorkflowID())
+		require.NoError(t, err, "failed to retrieve workflow")
 
-_, ok := pollingHandle.(*workflowPollingHandle[string])
-require.True(t, ok, "expected polling handle, got %T", pollingHandle)
+		_, ok := pollingHandle.(*workflowPollingHandle[string])
+		require.True(t, ok, "expected polling handle, got %T", pollingHandle)
 
-_, err = pollingHandle.GetResult(WithHandleTimeout(10*time.Millisecond), WithPollingInterval(1*time.Millisecond))
+		_, err = pollingHandle.GetResult(WithHandleTimeout(10*time.Millisecond), WithHandlePollingInterval(1*time.Millisecond))
 
-require.Error(t, err, "expected timeout error")
-assert.True(t, errors.Is(err, context.DeadlineExceeded),
-"expected error to be detectable as context.DeadlineExceeded, got: %v", err)
-})
+		require.Error(t, err, "expected timeout error")
+		assert.True(t, errors.Is(err, context.DeadlineExceeded),
+			"expected error to be detectable as context.DeadlineExceeded, got: %v", err)
+	})
 }
 
 func TestWorkflowHandleContextCancel(t *testing.T) {