Skip to content

Commit

Permalink
Fixing tests after knative/k8s updates
Browse files Browse the repository at this point in the history
Signed-off-by: Vincent Demeester <[email protected]>
  • Loading branch information
vdemeester committed Feb 3, 2025
1 parent c8cd83a commit 9a4c386
Show file tree
Hide file tree
Showing 2 changed files with 62 additions and 3 deletions.
59 changes: 57 additions & 2 deletions pkg/reconciler/taskrun/taskrun_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -196,6 +196,10 @@ var (
taskSidecar = &v1.Task{
ObjectMeta: objectMeta("test-task-sidecar", "foo"),
Spec: v1.TaskSpec{
Steps: []v1.Step{{
Name: "step1",
Image: "foo",
}},
Sidecars: []v1.Sidecar{{
Name: "sidecar1",
Image: "image-id",
Expand All @@ -205,6 +209,10 @@ var (
taskMultipleSidecars = &v1.Task{
ObjectMeta: objectMeta("test-task-sidecar", "foo"),
Spec: v1.TaskSpec{
Steps: []v1.Step{{
Name: "step1",
Image: "foo",
}},
Sidecars: []v1.Sidecar{
{
Name: "sidecar",
Expand Down Expand Up @@ -4283,10 +4291,12 @@ func TestReconcile_Single_SidecarState(t *testing.T) {
taskRun := parse.MustParseV1TaskRun(t, `
metadata:
name: test-taskrun-sidecars
namespace: foo
spec:
taskRef:
name: test-task-sidecar
status:
podName: test-taskrun-sidecars
sidecars:
- container: sidecar-sidecar
imageID: image-id
Expand All @@ -4295,16 +4305,34 @@ status:
startedAt: "2022-01-01T00:00:00Z"
`)

pod := &corev1.Pod{
ObjectMeta: objectMeta("test-taskrun-sidecars", "foo"),
Status: corev1.PodStatus{
ContainerStatuses: []corev1.ContainerStatus{{
Name: "sidecar-sidecar",
ImageID: "image-id",
State: corev1.ContainerState{
Running: &runningState,
},
}},
},
}

d := test.Data{
TaskRuns: []*v1.TaskRun{taskRun},
Tasks: []*v1.Task{taskSidecar},
Pods: []*corev1.Pod{pod},
}

testAssets, cancel := getTaskRunController(t, d)
defer cancel()
clients := testAssets.Clients

if err := testAssets.Controller.Reconciler.Reconcile(context.Background(), getRunName(taskRun)); err != nil {
createServiceAccount(t, testAssets, "default", taskRun.Namespace)

err := testAssets.Controller.Reconciler.Reconcile(context.Background(), getRunName(taskRun))
isRequeued, _ := controller.IsRequeueKey(err)
if err != nil && !isRequeued {
t.Errorf("expected no error reconciling valid TaskRun but got %v", err)
}

Expand All @@ -4321,6 +4349,7 @@ status:
Running: &runningState,
},
}
t.Logf("status: %v", getTaskRun.Status.Sidecars)

if c := cmp.Diff(expected, getTaskRun.Status.Sidecars[0]); c != "" {
t.Errorf("TestReconcile_Single_SidecarState %s", diff.PrintWantGot(c))
Expand All @@ -4333,10 +4362,12 @@ func TestReconcile_Multiple_SidecarStates(t *testing.T) {
taskRun := parse.MustParseV1TaskRun(t, `
metadata:
name: test-taskrun-sidecars
namespace: foo
spec:
taskRef:
name: test-task-sidecar
status:
podName: test-taskrun-sidecars
sidecars:
- container: sidecar-sidecar1
imageID: image-id
Expand All @@ -4349,17 +4380,40 @@ status:
waiting:
reason: PodInitializing
`)
pod := &corev1.Pod{
ObjectMeta: objectMeta("test-taskrun-sidecars", "foo"),
Status: corev1.PodStatus{
ContainerStatuses: []corev1.ContainerStatus{{
Name: "sidecar-sidecar1",
ImageID: "image-id",
State: corev1.ContainerState{
Running: &runningState,
},
}, {
Name: "sidecar-sidecar2",
ImageID: "image-id",
State: corev1.ContainerState{
Waiting: &waitingState,
},
}},
},
}

d := test.Data{
TaskRuns: []*v1.TaskRun{taskRun},
Tasks: []*v1.Task{taskMultipleSidecars},
Pods: []*corev1.Pod{pod},
}

testAssets, cancel := getTaskRunController(t, d)
defer cancel()
clients := testAssets.Clients

if err := testAssets.Controller.Reconciler.Reconcile(context.Background(), getRunName(taskRun)); err != nil {
createServiceAccount(t, testAssets, "default", taskRun.Namespace)

err := testAssets.Controller.Reconciler.Reconcile(context.Background(), getRunName(taskRun))
isRequeued, _ := controller.IsRequeueKey(err)
if err != nil && !isRequeued {
t.Errorf("expected no error reconciling valid TaskRun but got %v", err)
}

Expand Down Expand Up @@ -4387,6 +4441,7 @@ status:
},
}

t.Logf("status: %v", getTaskRun.Status.Sidecars)
for i, sc := range getTaskRun.Status.Sidecars {
if c := cmp.Diff(expected[i], sc); c != "" {
t.Errorf("TestReconcile_Multiple_SidecarStates sidecar%d %s", i+1, diff.PrintWantGot(c))
Expand Down
6 changes: 5 additions & 1 deletion pkg/status/status_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,7 @@ func TestGetTaskRunStatusForPipelineTask(t *testing.T) {
Name: "some-task-run",
PipelineTaskName: "some-task",
},
expectedStatus: &v1.TaskRunStatus{},
}, {
name: "success",
taskRun: parse.MustParseV1TaskRun(t, `
Expand Down Expand Up @@ -149,6 +150,7 @@ func TestGetRunStatusForPipelineTask(t *testing.T) {
Name: "some-run",
PipelineTaskName: "some-task",
},
expectedStatus: &v1beta1.CustomRunStatus{},
}, {
name: "success",
run: parse.MustParseCustomRun(t, `
Expand Down Expand Up @@ -300,7 +302,8 @@ pr-run-1:
value: rab
`),
expectedErr: nil,
}, {
},
{
name: "missing run",
originalPR: parse.MustParseV1PipelineRun(t, `
metadata:
Expand Down Expand Up @@ -337,6 +340,7 @@ pr-task-1:
expectedRunStatuses: mustParseRunStatusMap(t, `
pr-run-1:
pipelineTaskName: run-1
status: {}
`),
expectedErr: nil,
},
Expand Down

0 comments on commit 9a4c386

Please sign in to comment.