From 31685e3d1f1d3df7185da1827245e14d94ac82e6 Mon Sep 17 00:00:00 2001 From: ethanwee1 Date: Wed, 15 Jul 2026 20:04:23 +0000 Subject: [PATCH] [CI] Parity: read ROCm inductor from canonical trunk run (avoid periodic rerun_disabled trunk run) The ROCm inductor block resolved its own trunk run via download_workflow_run, which could return the periodic rerun_disabled_tests/mem_leak_check trunk run (only variant inductor jobs) instead of the canonical push run. Reuse trunk_full_wf like default/distributed already do. --- .../pytorch-unit-test-scripts/download_testlogs | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/.automation_scripts/pytorch-unit-test-scripts/download_testlogs b/.automation_scripts/pytorch-unit-test-scripts/download_testlogs index 8a0c6d778dffe..cfc1ef058ca42 100755 --- a/.automation_scripts/pytorch-unit-test-scripts/download_testlogs +++ b/.automation_scripts/pytorch-unit-test-scripts/download_testlogs @@ -842,10 +842,18 @@ def main(): print("===========================================") error_msg="Error: inductor workflow not found in scanned workflow runs. Try increasing max_pages." inductor_fallback_used = False - try: - inductor_wf_rocm = download_workflow_run(created=args.created, max_pages=args.max_pages, workflow=ROCmWorkflowNames["inductor"], sha=inductor_rocm_sha, ignore_status=args.ignore_status, status=status, error_msg=error_msg) - except (IndexError, Exception): - inductor_wf_rocm = None + if ROCmWorkflowNames["inductor"] == "trunk" and trunk_full_wf is not None: + # Read ROCm inductor from the canonical trunk push run (same as + # default/distributed above). Resolving a fresh trunk run here can + # land on the periodic rerun_disabled_tests/mem_leak_check trunk run, + # which only has the variant inductor jobs (a handful of flaky + # reruns) and makes the whole inductor suite look MISSED. + inductor_wf_rocm = trunk_full_wf + else: + try: + inductor_wf_rocm = download_workflow_run(created=args.created, max_pages=args.max_pages, workflow=ROCmWorkflowNames["inductor"], sha=inductor_rocm_sha, ignore_status=args.ignore_status, status=status, error_msg=error_msg) + except (IndexError, Exception): + inductor_wf_rocm = None inductor_fallbacks = _fallbacks_for("inductor") if inductor_wf_rocm is None and arch in inductor_fallbacks: fallback_wf, fallback_prefix = inductor_fallbacks[arch]