Skip to content

Commit aab8ab2

Browse files
committed
pkg/steps/lease: Split leased resource on '--'
To allow for the suffixed lease names from [1] without exposing the suffixes to consuming steps. [1]: openshift/release#12589
1 parent d6109df commit aab8ab2

File tree

2 files changed

+17
-2
lines changed

2 files changed

+17
-2
lines changed

pkg/steps/lease.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ import (
44
"context"
55
"errors"
66
"log"
7+
"strings"
78

89
utilerrors "k8s.io/apimachinery/pkg/util/errors"
910
coreclientset "k8s.io/client-go/kubernetes/typed/core/v1"
@@ -61,7 +62,8 @@ func (s *leaseStep) Provides() api.ParameterMap {
6162
parameters = api.ParameterMap{}
6263
}
6364
parameters[leaseEnv] = func() (string, error) {
64-
return s.leasedResource, nil
65+
chunks := strings.SplitN(s.leasedResource, "--", 2)
66+
return chunks[0], nil
6567
}
6668
return parameters
6769
}

pkg/steps/lease_test.go

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ func TestLeaseStepForward(t *testing.T) {
8585
t.Errorf("not properly forwarded: %s", diff.ObjectDiff(l, s))
8686
}
8787
})
88-
t.Run("Provides", func(t *testing.T) {
88+
t.Run("Provides includes parameters from wrapped step", func(t *testing.T) {
8989
sParam := step.Provides()
9090
sRet, err := sParam["parameter"]()
9191
if err != nil {
@@ -100,6 +100,19 @@ func TestLeaseStepForward(t *testing.T) {
100100
t.Errorf("not properly forwarded (param): %s", diff.ObjectDiff(lParam, sParam))
101101
}
102102
})
103+
t.Run("Provides includes sanitized lease name", func(t *testing.T) {
104+
rawLeaseStep := withLease.(*leaseStep)
105+
rawLeaseStep.leasedResource = "whatever--01"
106+
expected := "whatever"
107+
lParam := withLease.Provides()
108+
actual, err := lParam[leaseEnv]()
109+
if err != nil {
110+
t.Fatal(err)
111+
}
112+
if actual != expected {
113+
t.Errorf("got %q for %s, expected %q", actual, leaseEnv, expected)
114+
}
115+
})
103116
t.Run("SubTests", func(T *testing.T) {
104117
s, l := step.SubTests(), withLease.(subtestReporter).SubTests()
105118
if !reflect.DeepEqual(l, s) {

0 commit comments

Comments
 (0)