Skip to content

test: add retries + fix #125

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
gcheang merged 1 commit into from
Jun 11, 2026
+68 −6
Merged

test: add retries + fix #125

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 28 additions & 4 deletions ...test/java/com/ibm/cloud/continuous_delivery/cd_tekton_pipeline/v2/CdTektonPipelineIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,7 @@ public class CdTektonPipelineIT extends SdkIntegrationTestBase {
String triggerPropIdLink = null;
String runIdLink = null;
String rerunIdLink = null;
String runLogIdLink = null;
String propertyName = "prop1";
String triggerName = "start-deploy";
String triggerPropName = "triggerProp1";
Expand Down Expand Up @@ -878,7 +879,6 @@ public void testListTektonPipelineRunsWithPager() throws Exception {
}
}

/*
@Test(dependsOnMethods = { "testRerunTektonPipelineRun" })
public void testGetTektonPipelineRunLogs() throws Exception {
try {
Expand All @@ -895,6 +895,12 @@ public void testGetTektonPipelineRunLogs() throws Exception {

LogsCollection logsCollectionResult = response.getResult();
assertNotNull(logsCollectionResult);

// Store the first log ID for use in testGetTektonPipelineRunLogContent
if (logsCollectionResult.getLogs() != null && !logsCollectionResult.getLogs().isEmpty()) {
runLogIdLink = logsCollectionResult.getLogs().get(0).getId();
assertNotNull(runLogIdLink);
}
} catch (ServiceResponseException e) {
fail(String.format("Service returned status code %d: %s%nError details: %s",
e.getStatusCode(), e.getMessage(), e.getDebuggingInfo()));
Expand All @@ -907,11 +913,30 @@ public void testGetTektonPipelineRunLogContent() throws Exception {
GetTektonPipelineRunLogContentOptions getTektonPipelineRunLogContentOptions = new GetTektonPipelineRunLogContentOptions.Builder()
.pipelineId(pipelineIdLink)
.pipelineRunId(runIdLink)
.id()
.id(runLogIdLink)
.build();

// Invoke operation
Response<StepLog> response = pipelineSvc.getTektonPipelineRunLogContent(getTektonPipelineRunLogContentOptions).execute();
// Retry logic with exponential backoff to wait for log content to be available
Response<StepLog> response = null;
int maxRetries = 10;
long baseDelay = 1000L;
long maxDelay = 30000L;

for (int i = 0; i < maxRetries; i++) {
try {
response = pipelineSvc.getTektonPipelineRunLogContent(getTektonPipelineRunLogContentOptions).execute();
System.out.printf("Log content was retrieved successfully on attempt %d.%n", i + 1);
break;
} catch (Exception err) {
if (i == maxRetries - 1) {
throw err;
}
long retryDelay = Math.min(baseDelay * (1L << i), maxDelay);
System.out.printf("Attempt %d getting log content failed, retrying in %dms... Error: %s%n", i + 1, retryDelay, err.getMessage());
Thread.sleep(retryDelay);
}
}
// Validate response
assertNotNull(response);
assertEquals(response.getStatusCode(), 200);
Expand All @@ -923,7 +948,6 @@ public void testGetTektonPipelineRunLogContent() throws Exception {
e.getStatusCode(), e.getMessage(), e.getDebuggingInfo()));
}
}
*/


@Test(dependsOnMethods = { "testCreateTektonPipeline", "testCreateTektonPipelineRun", "testGetTektonPipelineRun", "testListTektonPipelineRuns", "testListTektonPipelineRunsWithPager" })
Expand Down
42 changes: 40 additions & 2 deletions ...lchain/src/test/java/com/ibm/cloud/continuous_delivery/cd_toolchain/v2/CdToolchainIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -326,7 +326,26 @@ public void testCreateToolchainEventApplicationJson() throws Exception {
.build();

// Invoke operation
Response<ToolchainEventPost> response = service.createToolchainEvent(createToolchainEventOptions).execute();
// Retry logic with exponential backoff to wait for event creation to succeed
Response<ToolchainEventPost> response = null;
int maxRetries = 10;
long baseDelay = 1000L;
long maxDelay = 30000L;

for (int i = 0; i < maxRetries; i++) {
try {
response = service.createToolchainEvent(createToolchainEventOptions).execute();
System.out.printf("Event was created successfully on attempt %d.%n", i + 1);
break;
} catch (Exception err) {
if (i == maxRetries - 1) {
throw err;
}
long retryDelay = Math.min(baseDelay * (1L << i), maxDelay);
System.out.printf("Attempt %d creating event failed, retrying in %dms... Error: %s%n", i + 1, retryDelay, err.getMessage());
Thread.sleep(retryDelay);
}
}
// Validate response
assertNotNull(response);
assertEquals(response.getStatusCode(), 200);
Expand Down Expand Up @@ -360,7 +379,26 @@ public void testCreateToolchainEventTextPlain() throws Exception {
.build();

// Invoke operation
Response<ToolchainEventPost> response = service.createToolchainEvent(createToolchainEventOptions).execute();
// Retry logic with exponential backoff to wait for event creation to succeed
Response<ToolchainEventPost> response = null;
int maxRetries = 10;
long baseDelay = 1000L;
long maxDelay = 30000L;

for (int i = 0; i < maxRetries; i++) {
try {
response = service.createToolchainEvent(createToolchainEventOptions).execute();
System.out.printf("Event was created successfully on attempt %d.%n", i + 1);
break;
} catch (Exception err) {
if (i == maxRetries - 1) {
throw err;
}
long retryDelay = Math.min(baseDelay * (1L << i), maxDelay);
System.out.printf("Attempt %d creating event failed, retrying in %dms... Error: %s%n", i + 1, retryDelay, err.getMessage());
Thread.sleep(retryDelay);
}
}
// Validate response
assertNotNull(response);
assertEquals(response.getStatusCode(), 200);
Expand Down