diff --git a/.github/workflows/ci-repeat.yml b/.github/workflows/ci-repeat.yml
new file mode 100644
index 00000000000..49e6d764cbf
--- /dev/null
+++ b/.github/workflows/ci-repeat.yml
@@ -0,0 +1,182 @@
+name: CI Repeat
+
+on:
+ # 监听名为 CI 的 workflow；只要它完整结束一次，就触发本 workflow
+ workflow_run:
+ workflows: ["CI"]
+ types: [completed]
+
+permissions:
+ # 需要写 Actions，才能发起 swap job 的 rerun
+ actions: write
+ contents: read
+ # 需要写 PR comment，记录每一轮 swap/test 的结果
+ pull-requests: write
+
+jobs:
+ repeat-swap:
+ # 仅处理 PR 场景；cancelled 不继续
+ if: >
+ github.event.workflow_run.event == 'pull_request' &&
+ github.event.workflow_run.conclusion != 'cancelled'
+ runs-on: ubuntu-24.04
+ env:
+ # 最多自动重跑多少轮；达到上限后只记录结果，不再继续触发
+ MAX_ATTEMPTS: "10"
+ steps:
+ - name: Record swap result and rerun if needed
+ uses: actions/github-script@v7
+ with:
+ script: |
+ const run = context.payload.workflow_run;
+ const owner = context.repo.owner;
+ const repo = context.repo.repo;
+ const runId = Number(run.id);
+ const runAttempt = Number(run.run_attempt || "1");
+ const maxAttempts = Number(process.env.MAX_ATTEMPTS || "10");
+ const marker = '';
+
+ if (!run.pull_requests || run.pull_requests.length === 0) {
+ core.info('No pull request is associated with this run.');
+ return;
+ }
+
+ const pr = run.pull_requests[0];
+ const jobs = await github.paginate(
+ github.rest.actions.listJobsForWorkflowRun,
+ {
+ owner,
+ repo,
+ run_id: runId,
+ per_page: 100,
+ }
+ );
+
+ const sanitizeLog = text => text.replace(/```/g, '``\u200b`');
+ const pickLogSnippet = text => {
+ const lines = text.replace(/\r\n/g, '\n').split('\n');
+ const needle = "couldn't open socket: connection refused";
+ const hit = lines.findIndex(line => line.includes(needle));
+
+ if (hit !== -1) {
+ const start = Math.max(0, hit - 200);
+ return lines.slice(start, hit + 1).join('\n').trimEnd();
+ }
+
+ return lines.slice(-200).join('\n').trimEnd();
+ };
+
+ const getJobLog = async jobId => {
+ try {
+ const response = await github.request(
+ 'GET /repos/{owner}/{repo}/actions/jobs/{job_id}/logs',
+ {
+ owner,
+ repo,
+ job_id: jobId,
+ request: { redirect: 'manual' },
+ }
+ );
+
+ const logUrl = response.headers.location;
+ if (!logUrl) {
+ return '(failed to get log download url)';
+ }
+
+ const logResponse = await fetch(logUrl, {
+ headers: {
+ 'User-Agent': 'actions/github-script',
+ },
+ });
+
+ if (!logResponse.ok) {
+ return `(failed to fetch logs: ${logResponse.status})`;
+ }
+
+ return await logResponse.text();
+ } catch (error) {
+ return `(failed to fetch logs: ${error.message})`;
+ }
+ };
+
+ const swapJob = jobs.find(job => /^swap(?:\s|\(|$)/.test(job.name));
+ const testStep = swapJob?.steps?.find(step => step.name?.toLowerCase() === 'test');
+
+ let swapLogSection = '_swap job not found_';
+ if (swapJob) {
+ const swapJobLog = await getJobLog(swapJob.id);
+ const snippet = sanitizeLog(pickLogSnippet(swapJobLog || ''));
+ swapLogSection =
+ `${swapJob.name} / test
\n\n` +
+ '```text\n' +
+ `${snippet || '(empty log)'}\n` +
+ '```\n' +
+ '${swapJob.name} / test
\n\n` +
+ '```text\n' +
+ `${snippet || '(empty log)'}\n` +
+ '```\n' +
+ '