We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1755700 commit 9d5f18dCopy full SHA for 9d5f18d
1 file changed
vxsort/smallsort/codegen/src/wave_engine.py
@@ -1120,13 +1120,6 @@ def _sigint_handler(_signum, _frame):
1120
)
1121
self._pending_jobs[stage_idx].extend(downstream_jobs)
1122
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
-
1130
self._sync_progress_totals(progress, stage_task_ids)
1131
tid = stage_task_ids.get(stage_idx)
1132
if tid is not None:
0 commit comments