t.Errorf("got backoff %s, want %s", backoff, step.wantBackoff)
			}

			// Simulate routine that continuously flushes the backoff queue.
			cl.Step(time.Millisecond)
			q.flushBackoffQCompleted(logger)
			// Still in backoff queue after an early flush.
			if _, ok, _ := q.podBackoffQ.Get(podInfo); !ok {
				t.Errorf("pod %v is not in the backoff queue", podID)
			}

			2, 0, 0, nil, "",
		},
		"suspending a job": {
			2, 4, 6,
			true, []int32{1, 1}, v1.PodRunning,
			0, 0, 0, &jobConditionSuspended, "JobSuspended",
		},
		"finshed job": {
			2, 4, 6,
			true, []int32{1, 1, 2, 0}, v1.PodSucceeded,
			0, 4, 0, &jobConditionComplete, "",
		},
	}

	for name, tc := range testCases {
		t.Run(name, func(t *testing.T) {