Skip to content

Commit 9d5f18d

Browse files
committed
fix: never skip stages in propagation loop
A wave always runs from target to last stage. Removed the has_work/continue guard that skipped stages with no pending jobs.
1 parent 1755700 commit 9d5f18d

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

vxsort/smallsort/codegen/src/wave_engine.py

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1120,13 +1120,6 @@ def _sigint_handler(_signum, _frame):
11201120
)
11211121
self._pending_jobs[stage_idx].extend(downstream_jobs)
11221122

1123-
has_work = (
1124-
self._pending_jobs[stage_idx]
1125-
or self._in_flight[stage_idx] > 0
1126-
)
1127-
if not has_work:
1128-
continue
1129-
11301123
self._sync_progress_totals(progress, stage_task_ids)
11311124
tid = stage_task_ids.get(stage_idx)
11321125
if tid is not None:

0 commit comments

Comments
 (0)