Skip to content

Commit

Permalink
deflake failure timeout test (#11422)
Browse files Browse the repository at this point in the history
  • Loading branch information
mfsiega-airbyte committed Feb 24, 2024
1 parent 34348f6 commit 34a46c0
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1086,7 +1086,9 @@ void testFailureTimeout() throws Exception {
testHarness.waitWhileJobHasStatus(runningJob, Sets.newHashSet(JobStatus.RUNNING), Duration.ofMinutes(3));

final JobInfoRead jobInfo = testHarness.getJobInfoRead(runningJob.getId());
final AttemptInfoRead attemptInfoRead = jobInfo.getAttempts().get(jobInfo.getAttempts().size() - 1);
// Only look at the first attempt. It's possible that in the time between leaving RUNNING and
// retrieving the job info, we'll have started a new attempt.
final AttemptInfoRead attemptInfoRead = jobInfo.getAttempts().get(0);

// assert that the job attempt failed, and cancel the job regardless of status to prevent retries
try {
Expand Down

0 comments on commit 34a46c0

Please sign in to comment.