Add a periodic tick sweep over the rollout cells - #2097
Conversation
|
Caution The consumer version of Gemini Code Assist on GitHub has been sunset. All code review activity has officially ceased. |
9a663a9 to
f3701c7
Compare
dde9aec to
a7b458d
Compare
0cfae7d to
2a9824b
Compare
a7b458d to
137f21d
Compare
2a9824b to
13811cb
Compare
137f21d to
58a69cf
Compare
13811cb to
2589578
Compare
58a69cf to
47c83b9
Compare
2589578 to
206df79
Compare
9abc46a to
d0fbbff
Compare
206df79 to
bfc30f2
Compare
d0fbbff to
d58254d
Compare
bfc30f2 to
e024b0e
Compare
a3ac4fb to
d825a69
Compare
9d64207 to
37be5f8
Compare
d825a69 to
29be034
Compare
37be5f8 to
5877b7a
Compare
88ea78b to
ca37002
Compare
97b950a to
cdc6b8b
Compare
6f8ab9a to
262ab1d
Compare
0bf7952 to
de3bffa
Compare
e5c5f0c to
3d17ff6
Compare
1122d4e to
e37180c
Compare
3d17ff6 to
4cd949d
Compare
e37180c to
8ff168d
Compare
4cd949d to
8eee1c8
Compare
8ff168d to
b2fa901
Compare
8eee1c8 to
72adb4a
Compare
The cell state machine is about to grow steps that must run outside the reconcile path. Add the driver for them: an empty per-cell tick plus the controller loop that sweeps every cell, survives a failing cell and is cancelled on teardown.
b2fa901 to
fd2f4ec
Compare
72adb4a to
cdfe05f
Compare
| self._task.cancel() | ||
| try: | ||
| await self._task | ||
| except asyncio.CancelledError: |
There was a problem hiding this comment.
[P2] Preserve cancellation from the disposing caller
SimpleTicker.dispose() catches every asyncio.CancelledError raised at this await, so it cannot distinguish the expected cancellation of self._task from cancellation of the task currently disposing the controller. If an outer shutdown deadline fires while this await is pending, that cancellation is swallowed and InferenceController.dispose() continues into watcher teardown instead of propagating it. This remains unchanged at safe-merge checkpoint #2176 and checked tip #2649. Please consume only the owned ticker task cancellation and add a deterministic test that cancels the dispose caller.
Part of #1837