Add test

Author: Sushisource

go.mod

@@ -2,8 +2,6 @@ module github.com/temporalio/cli
 
 go 1.24.5
 
-toolchain go1.24.6
-
 require (
 	github.com/BurntSushi/toml v1.4.0
 	github.com/alitto/pond v1.9.2
@@ -21,7 +19,7 @@ require (
 	go.temporal.io/api v1.52.0
 	go.temporal.io/sdk v1.35.0
 	go.temporal.io/sdk/contrib/envconfig v0.1.0
-	go.temporal.io/server v1.29.0-139.2
+	go.temporal.io/server v1.29.0-139.3
 	google.golang.org/grpc v1.72.2
 	google.golang.org/protobuf v1.36.6
 	gopkg.in/yaml.v3 v3.0.1

go.sum

@@ -408,8 +408,8 @@ go.temporal.io/sdk v1.35.0 h1:lRNAQ5As9rLgYa7HBvnmKyzxLcdElTuoFJ0FXM/AsLQ=
 go.temporal.io/sdk v1.35.0/go.mod h1:1q5MuLc2MEJ4lneZTHJzpVebW2oZnyxoIOWX3oFVebw=
 go.temporal.io/sdk/contrib/envconfig v0.1.0 h1:s+G/Ujph+Xl2jzLiiIm2T1vuijDkUL4Kse49dgDVGBE=
 go.temporal.io/sdk/contrib/envconfig v0.1.0/go.mod h1:FQEO3C56h9C7M6sDgSanB8HnBTmopw9qgVx4F1S6pJk=
-go.temporal.io/server v1.29.0-139.2 h1:chcQNcLX9rLj0JyEKG7+iN9+ysHLJ/g0DVJygN4aZFE=
-go.temporal.io/server v1.29.0-139.2/go.mod h1:OKFCSB0xxCX1Bmi2rYutWJEKppIrwuqx+c3e5GeY54w=
+go.temporal.io/server v1.29.0-139.3 h1:j4u7esLvLqzE67Q6s/ExvaFKOensFhskCWXe1VHyBdU=
+go.temporal.io/server v1.29.0-139.3/go.mod h1:OKFCSB0xxCX1Bmi2rYutWJEKppIrwuqx+c3e5GeY54w=
 go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
 go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
 go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=

temporalcli/commands.workflow_exec_test.go

@@ -17,6 +17,7 @@ import (
 	"github.com/google/uuid"
 	"go.temporal.io/api/common/v1"
 	"go.temporal.io/api/enums/v1"
+	"go.temporal.io/api/history/v1"
 	"go.temporal.io/api/workflowservice/v1"
 	"go.temporal.io/sdk/client"
 	"go.temporal.io/sdk/converter"
@@ -953,3 +954,50 @@ func (s *SharedServerSuite) testStartUpdateWithStartHelper(opts updateWithStartT
 	s.Equal(opts.expectedWfOutput["workflow"], wfReturn["workflow"])
 	s.Equal(opts.expectedWfOutput["update"], wfReturn["update"])
 }
+
+func (s *SharedServerSuite) TestWorkflow_Start_WithPriorityOptions() {
+	s.Worker().OnDevWorkflow(func(ctx workflow.Context, input any) (any, error) {
+		return "success", nil
+	})
+
+	workflowId := "priority-test-" + uuid.New().String()
+	res := s.Execute(
+		"workflow", "start",
+		"--address", s.Address(),
+		"--task-queue", s.Worker().Options.TaskQueue,
+		"--type", "DevWorkflow",
+		"--workflow-id", workflowId,
+		"--priority-key", "2",
+		"--fairness-key", "high-priority-tenant",
+		"--fairness-weight", "5.5",
+	)
+	s.NoError(res.Err)
+
+	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	defer cancel()
+
+	iter := s.Client.GetWorkflowHistory(ctx,
+		workflowId, "", false, enums.HISTORY_EVENT_FILTER_TYPE_ALL_EVENT)
+
+	var startedEvent *history.HistoryEvent
+	for iter.HasNext() {
+		event, err := iter.Next()
+		s.NoError(err)
+		if event.EventType == enums.EVENT_TYPE_WORKFLOW_EXECUTION_STARTED {
+			startedEvent = event
+			break
+		}
+	}
+
+	s.NotNil(startedEvent, "WorkflowExecutionStarted event not found")
+
+	startedAttrs := startedEvent.GetWorkflowExecutionStartedEventAttributes()
+	s.NotNil(startedAttrs, "WorkflowExecutionStarted attributes not found")
+
+	priority := startedAttrs.GetPriority()
+	s.NotNil(priority, "Priority not found in WorkflowExecutionStarted event")
+
+	s.Equal(int32(2), priority.GetPriorityKey())
+	s.Equal("high-priority-tenant", priority.GetFairnessKey())
+	s.Equal(float32(5.5), priority.GetFairnessWeight())
+}