Closed raubitsj closed 3 years ago
Changes Missing Coverage | Covered Lines | Changed/Added Lines | % | ||
---|---|---|---|---|---|
wandb/internal/handler.py | 3 | 4 | 75.0% | ||
wandb/internal/stats.py | 0 | 2 | 0.0% | ||
<!-- | Total: | 5 | 8 | 62.5% | --> |
Totals | |
---|---|
Change from base Build a70b1dbb-797e-440f-9280-04c037ab24bf: | 0.002% |
Covered Lines: | 12662 |
Relevant Lines: | 20996 |
add a new stats flush state to the run quiesce path (defer state machine)
TODO: document this :)
there is this shared state machine where each thread (handler, then sender) flushes its queues. since we have in order queues, the act of adding a defer message for the next state means that everything that might have been newly added during the previous state flush must have been handled by the time the next defer state is seen.