Lem0nTea2002 3791f27b38 fix(harness): enforce concurrency limits for retried Pregel tasks (#18496) ...

### Summary

`AsyncExecutor.Execute` acquires a worker-pool slot, while
`ExecuteWithRetry` duplicated the task lifecycle without acquiring one.
Pregel supplies a retry configuration for every node, so those
executions
bypassed `WithMaxConcurrency`.

This change:
- routes retry execution through the shared `Execute` path;
- waits on the task-owned context and rechecks cancellation after slot
acquisition;
- adds deterministic regression coverage for worker-pool occupancy and
queued-task cancellation.

2026-08-19 16:10:30 +08:00

..

channels

Refactor(harness): remove naive inline graph engine , unify graph execution under single pregel engine (#16608)

2026-07-03 17:50:30 +08:00

checkpoint

Go: fix warnings (#17738)

2026-08-03 21:30:01 +08:00

constants

Feat: add harness-go framework —— graph engine (#16039)

2026-06-15 21:36:39 +08:00

errors

Go: fix warnings (#17738)

2026-08-03 21:30:01 +08:00

graph

refactor: replace Split in loops with more efficient SplitSeq (#18248)

2026-08-17 19:04:04 +08:00

interrupt

Refactor harness framework (#16271)

2026-06-23 20:18:04 +08:00

managed

Go: fix warnings (#17738)

2026-08-03 21:30:01 +08:00

pregel

fix(harness): enforce concurrency limits for retried Pregel tasks (#18496)

2026-08-19 16:10:30 +08:00

runnable

Refactor harness framework (#16271)

2026-06-23 20:18:04 +08:00

store

Refactor harness framework (#16271)

2026-06-23 20:18:04 +08:00

task

Go: fix warnings (#17738)

2026-08-03 21:30:01 +08:00

types

refactor: use the built-in max/min to simplify the code (#17059)

2026-07-24 15:33:02 +08:00