Skip to content

chore(tests): add retry mechanism for e2e tests #7449

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
merged 2 commits into from
Oct 22, 2025
Merged

chore(tests): add retry mechanism for e2e tests #7449

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
40893d8
chore(tests): add retry mechanism for e2e tests
smilkuri Oct 22, 2025
9cc7b0e
chore(tests): fix retry logic to throw error on last attempt
smilkuri Oct 22, 2025
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
16 changes: 14 additions & 2 deletions tests/canary/canary.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ const testWorkspace = path.join(jsv3_root, "..", "canary-aws-sdk-js-v3");
});

verdaccioFork = await runRegistry(["-c", path.join(jsv3_root, "verdaccio", "config.yaml")]);
await localPublishChangedPackages(jsv3_root);
await retry(() => localPublishChangedPackages(jsv3_root));

await spawnProcess("npm", ["init", "-y"], { cwd: testWorkspace });
await spawnProcess("npm", ["install", `@aws-sdk/client-sts@ci`, "--registry", "http://localhost:4873/"], {
Expand Down Expand Up @@ -71,6 +71,18 @@ function runRegistry(args = [], childOptions = {}) {
});
}

async function retry(fn, attempts = 3) {
for (let i = 0; i < attempts; i++) {
try {
return await fn();
} catch (error) {
if (i === attempts - 1) throw error;
console.log(`Retry ${i + 1}/${attempts} failed, retrying...`);
await new Promise((resolve) => setTimeout(resolve, 2000));
}
}
}

async function localPublishChangedPackages(root) {
await spawnProcess("rm", ["-rf", "verdaccio/storage"], { cwd: root, stdio: "inherit" });

Expand All @@ -96,5 +108,5 @@ async function localPublishChangedPackages(root) {
"--dist-tag",
"ci",
];
await spawnProcess("npx", args, { cwd: root, stdio: "inherit" });
await retry(() => spawnProcess("npx", args, { cwd: root, stdio: "inherit" }));
}
Loading