Skip to content

Commit

Permalink
Fix changed names
Browse files Browse the repository at this point in the history
  • Loading branch information
Sushisource committed Mar 13, 2023
1 parent cee67ec commit 220e5f0
Show file tree
Hide file tree
Showing 3 changed files with 298 additions and 11 deletions.
20 changes: 10 additions & 10 deletions internal/worker_version_sets.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,20 +53,20 @@ func (uw *UpdateWorkerBuildIDCompatabilityOptions) validateAndConvertToProto() (
TaskQueue: uw.TaskQueue,
}
if uw.CompatibleVersion != "" {
req.Operation = &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_AddNewCompatibleVersion_{
AddNewCompatibleVersion: &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_AddNewCompatibleVersion{
NewVersionId: uw.WorkerBuildID,
ExistingCompatibleVersion: uw.CompatibleVersion,
req.Operation = &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_AddNewCompatibleBuildId{
AddNewCompatibleBuildId: &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_AddNewCompatibleVersion{
NewBuildId: uw.WorkerBuildID,
ExistingCompatibleBuildId: uw.CompatibleVersion,
MakeSetDefault: uw.BecomeDefault,
},
}
} else if uw.BecomeDefault {
req.Operation = &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_PromoteSetByVersionId{
PromoteSetByVersionId: uw.WorkerBuildID,
req.Operation = &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_PromoteSetByBuildId{
PromoteSetByBuildId: uw.WorkerBuildID,
}
} else {
req.Operation = &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_AddNewVersionIdInNewDefaultSet{
AddNewVersionIdInNewDefaultSet: uw.WorkerBuildID,
req.Operation = &workflowservice.UpdateWorkerBuildIdCompatabilityRequest_AddNewBuildIdInNewDefaultSet{
AddNewBuildIdInNewDefaultSet: uw.WorkerBuildID,
}
}

Expand Down Expand Up @@ -119,8 +119,8 @@ func workerVersionSetsFromProto(sets []*taskqueuepb.CompatibleVersionSet) []*Com
result := make([]*CompatibleVersionSet, len(sets))
for i, s := range sets {
result[i] = &CompatibleVersionSet{
id: s.GetId(),
Versions: s.GetVersions(),
id: s.GetVersionSetId(),
Versions: s.GetBuildIds(),
}
}
return result
Expand Down
1 change: 0 additions & 1 deletion test/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ require (
)

replace (
go.temporal.io/api => /mnt/chonky/dev/temporal/api-go
go.temporal.io/sdk => ../
go.temporal.io/sdk/contrib/opentelemetry => ../contrib/opentelemetry
go.temporal.io/sdk/contrib/opentracing => ../contrib/opentracing
Expand Down
Loading

0 comments on commit 220e5f0

Please sign in to comment.