Skip to content

Commit

Permalink
correct variable name
Browse files Browse the repository at this point in the history
  • Loading branch information
kaibocai committed Dec 1, 2023
1 parent 57ffa30 commit ea9d4f1
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions tests/grpc/grpc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -251,7 +251,7 @@ func Test_Grpc_ReuseInstanceIDSkip(t *testing.T) {

cancelListener := startGrpcListener(t, r)
defer cancelListener()
instanceIDs := api.InstanceID("SKIP_IF_RUNNING_OR_COMPLETED")
instanceID := api.InstanceID("SKIP_IF_RUNNING_OR_COMPLETED")
reuseIdOption := api.OrchestrationIDReuseOption{
CreateOrchestrationAction: protos.CreateOrchestrationAction_SKIP,
OrchestrationStatuses: []protos.OrchestrationStatus{
Expand All @@ -261,7 +261,7 @@ func Test_Grpc_ReuseInstanceIDSkip(t *testing.T) {
},
}

id, err := grpcClient.ScheduleNewOrchestration(ctx, "SingleActivity", api.WithInput("世界"), api.WithInstanceID(instanceIDs))
id, err := grpcClient.ScheduleNewOrchestration(ctx, "SingleActivity", api.WithInput("世界"), api.WithInstanceID(instanceID))
require.NoError(t, err)
// wait orchestration to start
grpcClient.WaitForOrchestrationStart(ctx, id)
Expand Down Expand Up @@ -303,7 +303,7 @@ func Test_Grpc_ReuseInstanceIDTerminate(t *testing.T) {

cancelListener := startGrpcListener(t, r)
defer cancelListener()
instanceIDs := api.InstanceID("TERMINATE_IF_RUNNING_OR_COMPLETED")
instanceID := api.InstanceID("TERMINATE_IF_RUNNING_OR_COMPLETED")
reuseIdOption := api.OrchestrationIDReuseOption{
CreateOrchestrationAction: protos.CreateOrchestrationAction_TERMINATE,
OrchestrationStatuses: []protos.OrchestrationStatus{
Expand All @@ -313,7 +313,7 @@ func Test_Grpc_ReuseInstanceIDTerminate(t *testing.T) {
},
}

id, err := grpcClient.ScheduleNewOrchestration(ctx, "SingleActivity", api.WithInput("世界"), api.WithInstanceID(instanceIDs))
id, err := grpcClient.ScheduleNewOrchestration(ctx, "SingleActivity", api.WithInput("世界"), api.WithInstanceID(instanceID))
require.NoError(t, err)
// wait orchestration to start
grpcClient.WaitForOrchestrationStart(ctx, id)
Expand Down Expand Up @@ -355,9 +355,9 @@ func Test_Grpc_ReuseInstanceIDThrow(t *testing.T) {

cancelListener := startGrpcListener(t, r)
defer cancelListener()
instanceIDs := api.InstanceID("THROW_IF_RUNNING_OR_COMPLETED")
instanceID := api.InstanceID("THROW_IF_RUNNING_OR_COMPLETED")

id, err := grpcClient.ScheduleNewOrchestration(ctx, "SingleActivity", api.WithInput("世界"), api.WithInstanceID(instanceIDs))
id, err := grpcClient.ScheduleNewOrchestration(ctx, "SingleActivity", api.WithInput("世界"), api.WithInstanceID(instanceID))
require.NoError(t, err)
id, err = grpcClient.ScheduleNewOrchestration(ctx, "SingleActivity", api.WithInput("世界"), api.WithInstanceID(id))
if assert.Error(t, err) {
Expand Down

0 comments on commit ea9d4f1

Please sign in to comment.