Rebuild the rollout cell around an explicit five-state machine - #2098
Rebuild the rollout cell around an explicit five-state machine#2098fzyzcjy wants to merge 1 commit into
Conversation
|
Caution The consumer version of Gemini Code Assist on GitHub has been sunset. All code review activity has officially ceased. |
b193c44 to
dde9aec
Compare
12ac8dd to
d0a6fbb
Compare
dde9aec to
a7b458d
Compare
d0a6fbb to
655543b
Compare
137f21d to
58a69cf
Compare
655543b to
e2ba0f1
Compare
58a69cf to
47c83b9
Compare
e2ba0f1 to
1105a58
Compare
47c83b9 to
9abc46a
Compare
1105a58 to
5ad47c4
Compare
9abc46a to
d0fbbff
Compare
5ad47c4 to
e8d08e6
Compare
d0fbbff to
d58254d
Compare
e8d08e6 to
2b256fc
Compare
d58254d to
a3ac4fb
Compare
2b256fc to
151b9f0
Compare
a3ac4fb to
d825a69
Compare
151b9f0 to
976fea2
Compare
29be034 to
042fa96
Compare
132d90c to
f4509ea
Compare
042fa96 to
ed0ca01
Compare
f4509ea to
d663cd0
Compare
88ea78b to
ca37002
Compare
d663cd0 to
86c5325
Compare
ca37002 to
6f8ab9a
Compare
090417b to
3e27670
Compare
6f8ab9a to
262ab1d
Compare
3e27670 to
59be169
Compare
45a326f to
e5c5f0c
Compare
59be169 to
d5dbcca
Compare
e5c5f0c to
3d17ff6
Compare
d5dbcca to
23d2588
Compare
3d17ff6 to
4cd949d
Compare
23d2588 to
17282a3
Compare
4cd949d to
8eee1c8
Compare
6ffe4a1 to
9b7a55e
Compare
72adb4a to
cdfe05f
Compare
9b7a55e to
736001d
Compare
|
|
||
| if not self.meta.update_weights or self.args.debug_rollout_only: | ||
| await self.mark_weights_ready() | ||
| self._change_state("mark_pending_weights", StateInitializing, StatePendingWeights(addr_info=addr_info)) |
There was a problem hiding this comment.
[P2] Make initialization retries phase-aware
_tick_when_initializing() keeps the cell in StateInitializing across snapshot, release, and resume. If release succeeds server-side but its response is lost, resume fails, or the tick is cancelled after release, the next sweep starts over and snapshots weights that may already have been discarded. This can corrupt the weight-checker baseline or leave a colocated engine stuck after a transient HTTP failure. Please persist or reconcile the completed startup phase so retries resume from the first incomplete operation instead of replaying the whole sequence.
A cell now starts uninitialized, releases its engine's launch gate in init(), and is carried to pending-weights by the tick sweep once the engine answers, instead of blocking the caller inside add(). Readiness polling moves from a blocking wait to a single short-timeout probe per tick, and dispose() is accepted from every state.
736001d to
9a80842
Compare
Part of #1837