()
| 212 | unfinished_states = [base.JOB_STATE_NEW, base.JOB_STATE_RUNNING] |
| 213 | |
| 214 | def get_queue_len(): |
| 215 | return self.trials.count_by_state_unsynced(unfinished_states) |
| 216 | |
| 217 | qlen = get_queue_len() |
| 218 | while qlen > 0: |
nothing calls this directly
no test coverage detected